BatchLogObserver.OnNextContext

All Superinterfaces:

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

Enclosing interface:

BatchLogObserver
```
@Stable
public static interface BatchLogObserver.OnNextContext
extends LogObserver.OnNextContext<Offset>
```
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
  
  long getWatermark()
  Retrieve current watermark of the observe process
  - Methods inherited from interface cz.o2.proxima.direct.core.LogObserver.OnNextContext
    getOffset, getPartition
  - Methods inherited from interface cz.o2.proxima.core.time.WatermarkSupplier
    getCurrentTime

- Method Detail
  - getWatermark
```
long getWatermark()
```
    Retrieve current watermark of the observe process
    
    Specified by:
    
    getWatermark in interface WatermarkSupplier
    
    Returns:
    
    watermark in milliseconds