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>
Constructor and Description |
---|
KafkaTopicPartitionStateWithPeriodicWatermarks(KafkaTopicPartition partition,
KPH kafkaPartitionHandle,
AssignerWithPeriodicWatermarks<T> timestampsAndWatermarks) |
Modifier and Type | Method and Description |
---|---|
long |
getCurrentWatermarkTimestamp() |
long |
getTimestampForRecord(T record,
long kafkaEventTimestamp) |
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, long kafkaEventTimestamp)
public long getCurrentWatermarkTimestamp()
public String toString()
toString
in class KafkaTopicPartitionState<KPH>
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.