org.apache.streams.elasticsearch

Class ElasticsearchPersistReader

java.lang.Object

org.apache.streams.elasticsearch.ElasticsearchPersistReader

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsPersistReader, StreamsProvider

public class ElasticsearchPersistReader
extends Object
implements StreamsPersistReader, Serializable

ElasticsearchPersistReader reads documents from elasticsearch.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ElasticsearchPersistReader.ElasticsearchPersistReaderTask

Field Summary

Fields

Modifier and Type	Field and Description
protected Queue<StreamsDatum>	persistQueue
static String	STREAMS_ID

Constructor Summary

Constructors

Constructor and Description
ElasticsearchPersistReader()
ElasticsearchPersistReader(ElasticsearchReaderConfiguration config)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
String	getId()
boolean	isRunning()
void	prepare(Object configuration)
StreamsResultSet	readAll()
StreamsResultSet	readCurrent()
StreamsResultSet	readNew(BigInteger sequence)
StreamsResultSet	readRange(org.joda.time.DateTime start, org.joda.time.DateTime end)
protected void	shutdownAndAwaitTermination(ExecutorService pool)
void	startStream()
protected void	write(StreamsDatum entry)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

STREAMS_ID

public static final String STREAMS_ID

See Also:

Constant Field Values

persistQueue

protected volatile Queue<StreamsDatum> persistQueue

Constructor Detail

ElasticsearchPersistReader

public ElasticsearchPersistReader()

ElasticsearchPersistReader

public ElasticsearchPersistReader(ElasticsearchReaderConfiguration config)

Method Detail

getId

public String getId()

Specified by:

getId in interface StreamsOperation

startStream

public void startStream()

Specified by:

startStream in interface StreamsProvider

prepare

public void prepare(Object configuration)

Specified by:

prepare in interface StreamsOperation

readAll

public StreamsResultSet readAll()

Specified by:

readAll in interface StreamsPersistReader

readCurrent

public StreamsResultSet readCurrent()

Specified by:

readCurrent in interface StreamsProvider

readNew

public StreamsResultSet readNew(BigInteger sequence)

Specified by:

readNew in interface StreamsPersistReader

Specified by:

readNew in interface StreamsProvider

readRange

public StreamsResultSet readRange(org.joda.time.DateTime start,
                                  org.joda.time.DateTime end)

Specified by:

readRange in interface StreamsPersistReader

Specified by:

readRange in interface StreamsProvider

isRunning

public boolean isRunning()

Specified by:

isRunning in interface StreamsProvider

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation

write

protected void write(StreamsDatum entry)

shutdownAndAwaitTermination

protected void shutdownAndAwaitTermination(ExecutorService pool)