Interface CommitLogObserver.OnIdleContext
-
- All Superinterfaces:
java.io.Serializable
,TimeProvider
,WatermarkSupplier
- Enclosing interface:
- CommitLogObserver
@Stable public static interface CommitLogObserver.OnIdleContext extends java.io.Serializable, WatermarkSupplier
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description long
getWatermark()
Retrieve watermark.-
Methods inherited from interface cz.o2.proxima.core.time.WatermarkSupplier
getCurrentTime
-
-
-
-
Method Detail
-
getWatermark
long getWatermark()
Description copied from interface:WatermarkSupplier
Retrieve watermark.- Specified by:
getWatermark
in interfaceWatermarkSupplier
- Returns:
- the current watermark.
-
-