Package cz.o2.proxima.direct.jdbc

Class JdbcBatchLogReader

java.lang.Object

cz.o2.proxima.core.storage.AbstractStorage

cz.o2.proxima.direct.jdbc.JdbcBatchLogReader

All Implemented Interfaces:

BatchLogReader

public class JdbcBatchLogReader
extends AbstractStorage
implements BatchLogReader

Nested Class Summary

Nested classes/interfaces inherited from class cz.o2.proxima.core.storage.AbstractStorage

AbstractStorage.SerializableAbstractStorage

Nested classes/interfaces inherited from interface cz.o2.proxima.direct.core.batch.BatchLogReader

BatchLogReader.Factory<T extends BatchLogReader>

Constructor Summary

Constructors

Constructor	Description
JdbcBatchLogReader(JdbcDataAccessor accessor, SqlStatementFactory sqlStatementFactory, EntityDescriptor entityDescriptor, java.net.URI uri, Factory<java.util.concurrent.ExecutorService> executorFactory)

Method Summary

Modifier and Type	Method	Description
BatchLogReader.Factory<?>	asFactory()	Convert instance of this reader to BatchLogReader.Factory suitable for serialization.
java.util.List<Partition>	getPartitions(long startStamp, long endStamp)	Retrieve list of partitions covering data from the given range.
ObserveHandle	observe(java.util.List<Partition> partitions, java.util.List<AttributeDescriptor<?>> attributes, BatchLogObserver observer)	Observe data stored in given partitions.

Methods inherited from class cz.o2.proxima.core.storage.AbstractStorage

equals, hashCode

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface cz.o2.proxima.direct.core.batch.BatchLogReader

getPartitions, getPartitions, observeOffsets

Constructor Detail

JdbcBatchLogReader

public JdbcBatchLogReader(JdbcDataAccessor accessor,
                          SqlStatementFactory sqlStatementFactory,
                          EntityDescriptor entityDescriptor,
                          java.net.URI uri,
                          Factory<java.util.concurrent.ExecutorService> executorFactory)

Method Detail

getPartitions

public java.util.List<Partition> getPartitions(long startStamp,
                                               long endStamp)

Description copied from interface: BatchLogReader

Retrieve list of partitions covering data from the given range.

Specified by:

getPartitions in interface BatchLogReader

Parameters:

startStamp - starting timestamp (inclusive)

endStamp - ending timestamp (exclusive)

Returns:

list of partitions covering the time range

observe

public ObserveHandle observe(java.util.List<Partition> partitions,
                             java.util.List<AttributeDescriptor<?>> attributes,
                             BatchLogObserver observer)

Description copied from interface: BatchLogReader

Observe data stored in given partitions.

Specified by:

observe in interface BatchLogReader

Parameters:

partitions - partitions to observe

attributes - attribute descriptors to filter out

observer - the observer by which to consume the data

Returns:

an ObserveHandle to control the consumption

asFactory

public BatchLogReader.Factory<?> asFactory()

Description copied from interface: BatchLogReader

Convert instance of this reader to BatchLogReader.Factory suitable for serialization.

Specified by:

asFactory in interface BatchLogReader

Returns:

the BatchLogReader.Factory representing this reader