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

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • cz.o2.proxima.direct.core.commitlog.CommitLogObservers
  • cz.o2.proxima.direct.core.commitlog.CommitLogObservers.ForwardingObserver (implements cz.o2.proxima.direct.core.commitlog.CommitLogObserver)
  • cz.o2.proxima.direct.core.commitlog.CommitLogReaders
  • cz.o2.proxima.direct.core.commitlog.CommitLogReaders.LimitedCommitLogReader
  • cz.o2.proxima.direct.core.commitlog.ObserveHandleUtils
  • cz.o2.proxima.direct.core.commitlog.ObserverUtils

Interface Hierarchy

• java.lang.AutoCloseable
  • cz.o2.proxima.direct.core.commitlog.ObserveHandle
• cz.o2.proxima.direct.core.commitlog.CommitLogObserver.OnRepartitionContext
• cz.o2.proxima.direct.core.commitlog.CommitLogReader
• cz.o2.proxima.direct.core.LogObserver<OffsetT,ContextT>
  • cz.o2.proxima.direct.core.commitlog.CommitLogObserver
• cz.o2.proxima.direct.core.commitlog.OffsetExternalizer
• java.io.Serializable
  • cz.o2.proxima.direct.core.commitlog.CommitLogObserver.OffsetCommitter
    • cz.o2.proxima.direct.core.commitlog.CommitLogObserver.OnNextContext (also extends cz.o2.proxima.direct.core.LogObserver.OnNextContext<OffsetT>)
  • cz.o2.proxima.direct.core.commitlog.CommitLogObserver.OnIdleContext (also extends cz.o2.proxima.core.time.WatermarkSupplier)
  • cz.o2.proxima.direct.core.commitlog.Offset
  • cz.o2.proxima.core.functional.TimeProvider
    • cz.o2.proxima.core.time.WatermarkSupplier
      • cz.o2.proxima.direct.core.commitlog.CommitLogObserver.OnIdleContext (also extends java.io.Serializable)
      • cz.o2.proxima.direct.core.LogObserver.OnNextContext<OffsetT>
        • cz.o2.proxima.direct.core.commitlog.CommitLogObserver.OnNextContext (also extends cz.o2.proxima.direct.core.commitlog.CommitLogObserver.OffsetCommitter)
  • cz.o2.proxima.core.functional.UnaryFunction<IN,OUT>
    • cz.o2.proxima.direct.core.commitlog.CommitLogReader.Factory<T>

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • cz.o2.proxima.direct.core.commitlog.CommitLogObservers.TerminationStrategy