Package | Description |
---|---|
org.apache.flink.connector.kafka.source | |
org.apache.flink.connector.kafka.source.enumerator |
Modifier and Type | Method and Description |
---|---|
SplitEnumerator<KafkaPartitionSplit,KafkaSourceEnumState> |
KafkaSource.createEnumerator(SplitEnumeratorContext<KafkaPartitionSplit> enumContext) |
SimpleVersionedSerializer<KafkaSourceEnumState> |
KafkaSource.getEnumeratorCheckpointSerializer() |
SplitEnumerator<KafkaPartitionSplit,KafkaSourceEnumState> |
KafkaSource.restoreEnumerator(SplitEnumeratorContext<KafkaPartitionSplit> enumContext,
KafkaSourceEnumState checkpoint) |
Modifier and Type | Method and Description |
---|---|
SplitEnumerator<KafkaPartitionSplit,KafkaSourceEnumState> |
KafkaSource.restoreEnumerator(SplitEnumeratorContext<KafkaPartitionSplit> enumContext,
KafkaSourceEnumState checkpoint) |
Modifier and Type | Method and Description |
---|---|
KafkaSourceEnumState |
KafkaSourceEnumStateSerializer.deserialize(int version,
byte[] serialized) |
KafkaSourceEnumState |
KafkaSourceEnumerator.snapshotState(long checkpointId) |
Modifier and Type | Method and Description |
---|---|
byte[] |
KafkaSourceEnumStateSerializer.serialize(KafkaSourceEnumState enumState) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.