public class FileBufferPersistReader extends Object implements StreamsPersistReader, Serializable
Modifier and Type | Field and Description |
---|---|
protected Queue<StreamsDatum> |
persistQueue |
static String |
STREAMS_ID |
Constructor and Description |
---|
FileBufferPersistReader() |
FileBufferPersistReader(FileBufferConfiguration config) |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
String |
getId() |
boolean |
isRunning() |
void |
prepare(Object configurationObject) |
StreamsResultSet |
readAll() |
StreamsResultSet |
readCurrent() |
StreamsResultSet |
readNew(BigInteger bigInteger) |
StreamsResultSet |
readRange(org.joda.time.DateTime dateTime,
org.joda.time.DateTime dateTime2) |
void |
startStream() |
public static final String STREAMS_ID
protected volatile Queue<StreamsDatum> persistQueue
public FileBufferPersistReader()
public FileBufferPersistReader(FileBufferConfiguration config)
public String getId()
getId
in interface StreamsOperation
public StreamsResultSet readAll()
readAll
in interface StreamsPersistReader
public void startStream()
startStream
in interface StreamsProvider
public StreamsResultSet readCurrent()
readCurrent
in interface StreamsProvider
public StreamsResultSet readNew(BigInteger bigInteger)
readNew
in interface StreamsPersistReader
readNew
in interface StreamsProvider
public StreamsResultSet readRange(org.joda.time.DateTime dateTime, org.joda.time.DateTime dateTime2)
readRange
in interface StreamsPersistReader
readRange
in interface StreamsProvider
public boolean isRunning()
isRunning
in interface StreamsProvider
public void prepare(Object configurationObject)
prepare
in interface StreamsOperation
public void cleanUp()
cleanUp
in interface StreamsOperation
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.