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

Class ObserverUtils

java.lang.Object

cz.o2.proxima.direct.core.commitlog.ObserverUtils

@Internal
public class ObserverUtils
extends java.lang.Object

Various utilities for working with CommitLogObserver.

Method Summary

Modifier and Type	Method	Description
static CommitLogObserver.OnIdleContext	asOnIdleContext(WatermarkSupplier supplier)
static CommitLogObserver.OnNextContext	asOnNextContext(CommitLogObserver.OffsetCommitter committer, Offset offset)
static CommitLogObserver.OnRepartitionContext	asRepartitionContext(java.util.Collection<Partition> assigned)

Methods inherited from class java.lang.Object

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

Method Detail

asOnNextContext

public static CommitLogObserver.OnNextContext asOnNextContext(CommitLogObserver.OffsetCommitter committer,
                                                              Offset offset)

asRepartitionContext

public static CommitLogObserver.OnRepartitionContext asRepartitionContext(java.util.Collection<Partition> assigned)

asOnIdleContext

public static CommitLogObserver.OnIdleContext asOnIdleContext(WatermarkSupplier supplier)