public final class StreamIndexer extends Object implements org.culturegraph.mf.framework.StreamReceiver
StreamReceiver
) to a Lucene Index. Still
prototypical!Constructor and Description |
---|
StreamIndexer(org.apache.lucene.index.IndexWriter indexWriter) |
StreamIndexer(org.apache.lucene.index.IndexWriter indexWriter,
org.culturegraph.mf.morph.Metamorph metamorph) |
Modifier and Type | Method and Description |
---|---|
void |
closeStream() |
void |
endEntity() |
void |
endRecord() |
int |
getBatchSize() |
int |
getCount() |
org.apache.lucene.index.IndexWriter |
getIndexWriter() |
void |
literal(String name,
String value) |
void |
resetStream() |
void |
setBatchSize(int batchSize) |
void |
startEntity(String name) |
void |
startRecord(String identifier) |
public StreamIndexer(org.apache.lucene.index.IndexWriter indexWriter)
public StreamIndexer(org.apache.lucene.index.IndexWriter indexWriter, org.culturegraph.mf.morph.Metamorph metamorph)
public org.apache.lucene.index.IndexWriter getIndexWriter()
public int getCount()
public void startRecord(String identifier)
startRecord
in interface org.culturegraph.mf.framework.StreamReceiver
public void endRecord()
endRecord
in interface org.culturegraph.mf.framework.StreamReceiver
public void startEntity(String name)
startEntity
in interface org.culturegraph.mf.framework.StreamReceiver
public void endEntity()
endEntity
in interface org.culturegraph.mf.framework.StreamReceiver
public void literal(String name, String value)
literal
in interface org.culturegraph.mf.framework.StreamReceiver
public void resetStream()
resetStream
in interface org.culturegraph.mf.framework.LifeCycle
public void closeStream()
closeStream
in interface org.culturegraph.mf.framework.LifeCycle
public void setBatchSize(int batchSize)
public int getBatchSize()
Copyright © 2015. All Rights Reserved.