org.apache.streams.core

Interface StreamsPersistReader

All Superinterfaces:

Serializable, StreamsOperation, StreamsProvider

public interface StreamsPersistReader
extends StreamsProvider

Currently a duplicate interface. Has exact same methods as StreamsProvider.

Method Summary

Modifier and Type	Method and Description
StreamsResultSet	readAll()
StreamsResultSet	readNew(BigInteger sequence) Read data with sequenceId greater than sequence.
StreamsResultSet	readRange(org.joda.time.DateTime start, org.joda.time.DateTime end) Read data with event time between start DateTime and end DateTime.

Methods inherited from interface org.apache.streams.core.StreamsProvider

isRunning, readCurrent, startStream

Methods inherited from interface org.apache.streams.core.StreamsOperation

cleanUp, getId, prepare

Method Detail

readAll

StreamsResultSet readAll()

readNew

StreamsResultSet readNew(BigInteger sequence)

Description copied from interface: StreamsProvider

Read data with sequenceId greater than sequence.

Specified by:

readNew in interface StreamsProvider

Parameters:

sequence - BigInteger sequence

Returns:

StreamsResultSet

readRange

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

Description copied from interface: StreamsProvider

Read data with event time between start DateTime and end DateTime.

Specified by:

readRange in interface StreamsProvider

Parameters:

start - start DateTime

end - end DateTime

Returns:

StreamsResultSet