public class FileBufferPersistReader extends Object implements StreamsPersistReader, Serializable
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 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 © 2017 The Apache Software Foundation. All rights reserved.