org.apache.streams.neo4j.bolt

Class Neo4jBoltPersistReader

java.lang.Object

org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsPersistReader, StreamsProvider

public class Neo4jBoltPersistReader
extends Object
implements StreamsPersistReader

Neo4jBoltPersistReader reads documents from neo4j.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	Neo4jBoltPersistReader.Neo4jBoltPersistReaderTask

Field Summary

Fields

Modifier and Type	Field and Description
protected Neo4jBoltClient	client
protected ReadWriteLock	lock
static org.slf4j.Logger	LOGGER
protected Queue<StreamsDatum>	persistQueue
protected org.neo4j.driver.v1.StatementResult	statementResult
static String	STREAMS_ID

Constructor Summary

Constructors

Constructor and Description
Neo4jBoltPersistReader() Neo4jBoltPersistReader constructor - resolves Neo4jReaderConfiguration from JVM 'neo4j'.
Neo4jBoltPersistReader(Neo4jReaderConfiguration config) Neo4jBoltPersistReader constructor - uses supplied Neo4jReaderConfiguration.
Neo4jBoltPersistReader(Queue<StreamsDatum> persistQueue) Neo4jBoltPersistReader constructor - uses supplied persistQueue.

Method Summary

Modifier and Type	Method and Description
protected Optional<StreamsDatum>	buildDatum(org.neo4j.driver.v1.Record record)
void	cleanUp()
String	getId()
Queue<StreamsDatum>	getPersistQueue()
boolean	isRunning()
void	prepare(Object configurationObject)
StreamsResultSet	readAll()
StreamsResultSet	readCurrent()
StreamsResultSet	readNew(BigInteger sequence)
StreamsResultSet	readRange(org.joda.time.DateTime start, org.joda.time.DateTime end)
void	setPersistQueue(Queue<StreamsDatum> persistQueue)
void	startStream()
void	stop()
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

LOGGER

public static final org.slf4j.Logger LOGGER

persistQueue

protected volatile Queue<StreamsDatum> persistQueue

client

protected Neo4jBoltClient client

statementResult

protected org.neo4j.driver.v1.StatementResult statementResult

lock

protected final ReadWriteLock lock

Constructor Detail

Neo4jBoltPersistReader

public Neo4jBoltPersistReader()

Neo4jBoltPersistReader constructor - resolves Neo4jReaderConfiguration from JVM 'neo4j'.

Neo4jBoltPersistReader

public Neo4jBoltPersistReader(Neo4jReaderConfiguration config)

Neo4jBoltPersistReader constructor - uses supplied Neo4jReaderConfiguration.

Parameters:

config - config

Neo4jBoltPersistReader

public Neo4jBoltPersistReader(Queue<StreamsDatum> persistQueue)

Neo4jBoltPersistReader constructor - uses supplied persistQueue.

Parameters:

persistQueue - persistQueue

Method Detail

setPersistQueue

public void setPersistQueue(Queue<StreamsDatum> persistQueue)

getPersistQueue

public Queue<StreamsDatum> getPersistQueue()

stop

public void stop()

getId

public String getId()

Specified by:

getId in interface StreamsOperation

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation

buildDatum

protected Optional<StreamsDatum> buildDatum(org.neo4j.driver.v1.Record record)

readAll

public StreamsResultSet readAll()

Specified by:

readAll in interface StreamsPersistReader

startStream

public void startStream()

Specified by:

startStream in interface StreamsProvider

readCurrent

public StreamsResultSet readCurrent()

Specified by:

readCurrent in interface StreamsProvider

write

protected void write(StreamsDatum entry)

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