Package cz.o2.proxima.direct.core.batch

Class BatchLogReaders

java.lang.Object

cz.o2.proxima.direct.core.batch.BatchLogReaders

public class BatchLogReaders
extends java.lang.Object

Class constructing various BatchLogReaders.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BatchLogReaders.ForwardingBatchLogObserver

Method Summary

Modifier and Type	Method	Description
static BatchLogReader	withLimitedThroughput(BatchLogReader delegate, ThroughputLimiter limiter)	Create throughput limited BatchLogReader.

Methods inherited from class java.lang.Object

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

Method Detail

withLimitedThroughput

public static BatchLogReader withLimitedThroughput(BatchLogReader delegate,
                                                   @Nullable
                                                   ThroughputLimiter limiter)

Create throughput limited BatchLogReader.

Parameters:

delegate - delegate to read data from

limiter - the throughput limiter

Returns:

throughput limited BatchLogReader