T
- The type of records handled by the watermark generatorKPH
- The type of the Kafka partition descriptor, which varies across Kafka versions.public final class KafkaTopicPartitionStateWithPeriodicWatermarks<T,KPH> extends KafkaTopicPartitionState<KPH>
OFFSET_NOT_SET
Constructor and Description |
---|
KafkaTopicPartitionStateWithPeriodicWatermarks(KafkaTopicPartition partition,
KPH kafkaPartitionHandle,
AssignerWithPeriodicWatermarks<T> timestampsAndWatermarks) |
Modifier and Type | Method and Description |
---|---|
long |
getCurrentWatermarkTimestamp() |
long |
getTimestampForRecord(T record) |
String |
toString() |
getCommittedOffset, getKafkaPartitionHandle, getKafkaTopicPartition, getOffset, getPartition, getTopic, isOffsetDefined, setCommittedOffset, setOffset
public KafkaTopicPartitionStateWithPeriodicWatermarks(KafkaTopicPartition partition, KPH kafkaPartitionHandle, AssignerWithPeriodicWatermarks<T> timestampsAndWatermarks)
public long getTimestampForRecord(T record)
public long getCurrentWatermarkTimestamp()
public String toString()
toString
in class KafkaTopicPartitionState<KPH>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.