Skip to content

Commit

Permalink
Cleanup of LuceneDocumentStructure
Browse files Browse the repository at this point in the history
  • Loading branch information
ragadeeshu committed Feb 27, 2017
1 parent 3cdb074 commit 132c81b
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 17 deletions.
Expand Up @@ -49,6 +49,7 @@
import java.io.IOException; import java.io.IOException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.EnumMap; import java.util.EnumMap;
import java.util.HashMap;
import java.util.Iterator; import java.util.Iterator;
import java.util.Map; import java.util.Map;


Expand Down Expand Up @@ -255,8 +256,7 @@ private static class DocWithId
private final Field idField; private final Field idField;
private final Field idValueField; private final Field idValueField;


private final Map<ValueEncoding,Field> valueFields = new EnumMap<>( ValueEncoding.class ); private final Map<String,Field> valueFields = new HashMap<>();
private final ArrayList<Map<ValueEncoding,Field>> compositeValueFields = new ArrayList<>();


private DocWithId() { private DocWithId() {
idField = new StringField( NODE_ID_KEY, "", YES ); idField = new StringField( NODE_ID_KEY, "", YES );
Expand Down Expand Up @@ -297,23 +297,14 @@ private void removeAllValueFields()
} }
} }


private Map<ValueEncoding,Field> getValueFields( int compositeKey )
{
while ( compositeValueFields.size() <= compositeKey )
{
compositeValueFields.add( new EnumMap<>( ValueEncoding.class ) );
}
return compositeValueFields.get( compositeKey );
}

private Field getFieldWithValue( int propertyNumber, ValueEncoding encoding, Object value ) private Field getFieldWithValue( int propertyNumber, ValueEncoding encoding, Object value )
{ {
Map<ValueEncoding,Field> compositeValueField = getValueFields( propertyNumber ); String key = encoding.key( propertyNumber );
Field reusableField = compositeValueField.get( encoding ); Field reusableField = valueFields.get( key );
if ( reusableField == null ) if ( reusableField == null )
{ {
reusableField = encoding.encodeField( encoding.key( propertyNumber ), value ); reusableField = encoding.encodeField( key, value );
compositeValueField.put( encoding, reusableField ); valueFields.put( key, reusableField );
} }
else else
{ {
Expand Down
Expand Up @@ -297,7 +297,7 @@ private void insert( Collection<PropertyValue> data ) throws IOException
PropertyValue[] dataArray = data.toArray( new PropertyValue[data.size()] ); PropertyValue[] dataArray = data.toArray( new PropertyValue[data.size()] );
for ( int i = 0; i < dataArray.length; i++ ) for ( int i = 0; i < dataArray.length; i++ )
{ {
Document doc = LuceneDocumentStructure.documentRepresentingProperties( (long) i, dataArray[i].value ); Document doc = LuceneDocumentStructure.documentRepresentingProperties( i, dataArray[i].value );
index.getIndexWriter().addDocument( doc ); index.getIndexWriter().addDocument( doc );
} }
index.maybeRefreshBlocking(); index.maybeRefreshBlocking();
Expand Down
Expand Up @@ -277,7 +277,7 @@ private void insert( List<Object> data ) throws IOException
{ {
for ( int i = 0; i < data.size(); i++ ) for ( int i = 0; i < data.size(); i++ )
{ {
Document doc = LuceneDocumentStructure.documentRepresentingProperties( (long) i, data.get( i ) ); Document doc = LuceneDocumentStructure.documentRepresentingProperties( i, data.get( i ) );
writer.addDocument( doc ); writer.addDocument( doc );
} }
searcherManager.maybeRefreshBlocking(); searcherManager.maybeRefreshBlocking();
Expand Down

0 comments on commit 132c81b

Please sign in to comment.