LogObserver.OnNextContext

All Superinterfaces:

java.io.Serializable, TimeProvider, WatermarkSupplier

All Known Subinterfaces:

BatchLogObserver.OnNextContext, CommitLogObserver.OnNextContext

Enclosing interface:

LogObserver<OffsetT extends java.io.Serializable,ContextT extends LogObserver.OnNextContext<OffsetT>>
```
@Stable
public static interface LogObserver.OnNextContext<OffsetT extends java.io.Serializable>
extends WatermarkSupplier
```
Context passed to LogObserver.onNext(cz.o2.proxima.core.storage.StreamElement, ContextT).

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`OffsetT`	`getOffset()`	Retrieve offset of the current element.
`Partition`	`getPartition()`	Retrieve partition for currently processed record.

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

- Method Detail
  - getPartition
```
Partition getPartition()
```
    Retrieve partition for currently processed record.
    
    Returns:
    
    partition of currently processed record
  - getOffset
```
OffsetT getOffset()
```
    Retrieve offset of the current element.
    
    Returns:
    
    Offset.