Package cz.o2.proxima.direct.core.commitlog

Class CommitLogReaders

java.lang.Object

cz.o2.proxima.direct.core.commitlog.CommitLogReaders

@Internal
public class CommitLogReaders
extends java.lang.Object

Utility class that constructs various versions of CommitLogReaders.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CommitLogReaders.LimitedCommitLogReader

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Detail

withThroughputLimit

public static CommitLogReader withThroughputLimit(CommitLogReader delegate,
                                                  @Nullable
                                                  ThroughputLimiter limiter)

Create throughput limited CommitLogReader.

Parameters:

delegate - delegate to read data from

limiter - the throughput limiter

Returns:

throughput limited CommitLogReader