Interface Offset
-
- All Superinterfaces:
java.io.Serializable
@Stable public interface Offset extends java.io.Serializable
Interface for implementations and their offset.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Partition
getPartition()
Which partition is this offset forlong
getWatermark()
Retrieve watermark associated with this offset.
-
-
-
Method Detail
-
getPartition
Partition getPartition()
Which partition is this offset for- Returns:
- partition of offset
-
getWatermark
long getWatermark()
Retrieve watermark associated with this offset.- Returns:
- watermark associated with this offset
-
-