Class KafkaCheckpointMark.PartitionMark

java.lang.Object
org.apache.beam.sdk.io.kafka.KafkaCheckpointMark.PartitionMark
All Implemented Interfaces:
Serializable
Enclosing class:
KafkaCheckpointMark

public static class KafkaCheckpointMark.PartitionMark extends Object implements Serializable
A tuple to hold topic, partition, and offset that comprise the checkpoint for a single partition.
See Also:
  • Constructor Details

    • PartitionMark

      public PartitionMark(String topic, int partition, long offset, long watermarkMillis)
  • Method Details

    • getTopic

      public String getTopic()
    • getPartition

      public int getPartition()
    • getNextOffset

      public long getNextOffset()
    • getWatermarkMillis

      public long getWatermarkMillis()
    • toString

      public String toString()
      Overrides:
      toString in class Object