CommitLogObserver.OnNextContext

All Superinterfaces:

CommitLogObserver.OffsetCommitter, LogObserver.OnNextContext<Offset>, java.io.Serializable, TimeProvider, WatermarkSupplier

Enclosing interface:

CommitLogObserver
```
@Stable
public static interface CommitLogObserver.OnNextContext
extends LogObserver.OnNextContext<Offset>, CommitLogObserver.OffsetCommitter
```
Context passed to LogObserver.onNext(cz.o2.proxima.core.storage.StreamElement, ContextT).

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	Description
`default void`	`commit(boolean success, java.lang.Throwable error)`	Confirm processing of element.
`CommitLogObserver.OffsetCommitter`	`committer()`	Retrieve committer for currently processed record.

Methods inherited from interface cz.o2.proxima.direct.core.commitlog.CommitLogObserver.OffsetCommitter
confirm, fail, nack

Methods inherited from interface cz.o2.proxima.direct.core.LogObserver.OnNextContext
getOffset, getPartition

Methods inherited from interface cz.o2.proxima.core.time.WatermarkSupplier
getCurrentTime, getWatermark

- Method Detail
  - committer
```
CommitLogObserver.OffsetCommitter committer()
```
    Retrieve committer for currently processed record.
    
    Returns:
    
    offset committer to use for committing
  - commit
```
default void commit(boolean success,
                    java.lang.Throwable error)
```
    Description copied from interface: CommitLogObserver.OffsetCommitter
    
    Confirm processing of element.
    
    Specified by:
    
    commit in interface CommitLogObserver.OffsetCommitter
    
    Parameters:
    
    success - success/fail flag
    
    error - error that was thrown during processing