public interface StreamsPersistReader extends StreamsProvider
Modifier and Type | Method and Description |
---|---|
StreamsResultSet |
readAll() |
StreamsResultSet |
readNew(BigInteger sequence)
TODO: Define how this operates or eliminate
|
StreamsResultSet |
readRange(org.joda.time.DateTime start,
org.joda.time.DateTime end)
TODO: Define how this operates or eliminate
|
isRunning, readCurrent, startStream
cleanUp, getId, prepare
StreamsResultSet readAll()
StreamsResultSet readNew(BigInteger sequence)
StreamsProvider
readNew
in interface StreamsProvider
StreamsResultSet readRange(org.joda.time.DateTime start, org.joda.time.DateTime end)
StreamsProvider
readRange
in interface StreamsProvider
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.