org.apache.flink.streaming.connectors.kafka.internals

Class KafkaTopicPartitionStateWithWatermarkGenerator<T,KPH>

java.lang.Object

org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartitionState<T,KPH>

org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartitionStateWithWatermarkGenerator<T,KPH>

Type Parameters:

T - The type of records handled by the watermark generator

KPH - The type of the Kafka partition descriptor, which varies across Kafka versions.

@Internal
public final class KafkaTopicPartitionStateWithWatermarkGenerator<T,KPH>
extends KafkaTopicPartitionState<T,KPH>

A special version of the per-kafka-partition-state that additionally holds a TimestampAssigner, WatermarkGenerator, an immediate WatermarkOutput, and a deferred WatermarkOutput for this partition.

See WatermarkOutputMultiplexer for an explanation of immediate and deferred WatermarkOutputs..

Constructor Summary

Constructors

Constructor and Description
KafkaTopicPartitionStateWithWatermarkGenerator(KafkaTopicPartition partition, KPH kafkaPartitionHandle, TimestampAssigner<T> timestampAssigner, WatermarkGenerator<T> watermarkGenerator, WatermarkOutput immediateOutput, WatermarkOutput deferredOutput)

Method Summary

Modifier and Type	Method and Description
long	extractTimestamp(T record, long kafkaEventTimestamp)
void	onEvent(T event, long timestamp)
void	onPeriodicEmit()
String	toString()

Methods inherited from class org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartitionState

getCommittedOffset, getKafkaPartitionHandle, getKafkaTopicPartition, getOffset, getPartition, getTopic, isOffsetDefined, setCommittedOffset, setOffset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaTopicPartitionStateWithWatermarkGenerator

public KafkaTopicPartitionStateWithWatermarkGenerator(KafkaTopicPartition partition,
                                                      KPH kafkaPartitionHandle,
                                                      TimestampAssigner<T> timestampAssigner,
                                                      WatermarkGenerator<T> watermarkGenerator,
                                                      WatermarkOutput immediateOutput,
                                                      WatermarkOutput deferredOutput)

Method Detail

extractTimestamp

public long extractTimestamp(T record,
                             long kafkaEventTimestamp)

Overrides:

extractTimestamp in class KafkaTopicPartitionState<T,KPH>

onEvent

public void onEvent(T event,
                    long timestamp)

Overrides:

onEvent in class KafkaTopicPartitionState<T,KPH>

onPeriodicEmit

public void onPeriodicEmit()

Overrides:

onPeriodicEmit in class KafkaTopicPartitionState<T,KPH>

toString

public String toString()

Overrides:

toString in class KafkaTopicPartitionState<T,KPH>