Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka.internals |
Modifier and Type | Class and Description |
---|---|
static class |
KafkaShuffleFetcher.KafkaShuffleRecord<T>
One value with Type T in a KafkaShuffle.
|
static class |
KafkaShuffleFetcher.KafkaShuffleWatermark
A watermark element in a KafkaShuffle.
|
Modifier and Type | Method and Description |
---|---|
KafkaShuffleFetcher.KafkaShuffleElement |
KafkaShuffleFetcher.KafkaShuffleElementDeserializer.deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.