@VisibleForTesting public static class KafkaShuffleFetcher.KafkaShuffleElementDeserializer<T> extends Object implements Serializable
Constructor and Description |
---|
KafkaShuffleElementDeserializer(TypeSerializer<T> typeSerializer) |
Modifier and Type | Method and Description |
---|---|
KafkaShuffleFetcher.KafkaShuffleElement |
deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record) |
@VisibleForTesting public KafkaShuffleElementDeserializer(TypeSerializer<T> typeSerializer)
@VisibleForTesting public KafkaShuffleFetcher.KafkaShuffleElement deserialize(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record) throws Exception
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.