Uses of Interface
org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema

Packages that use KafkaDeserializationSchema

Package	Description
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.kafka.internal
org.apache.flink.streaming.connectors.kafka.internals
org.apache.flink.streaming.util.serialization

Uses of KafkaDeserializationSchema in org.apache.flink.streaming.connectors.kafka

Fields in org.apache.flink.streaming.connectors.kafka declared as KafkaDeserializationSchema

Modifier and Type	Field and Description
protected KafkaDeserializationSchema<T>	FlinkKafkaConsumerBase.deserializer The schema to convert between Kafka's byte messages, and Flink's objects.

Constructors in org.apache.flink.streaming.connectors.kafka with parameters of type KafkaDeserializationSchema

Constructor and Description
FlinkKafkaConsumer(List<String> topics, KafkaDeserializationSchema<T> deserializer, Properties props) Creates a new Kafka streaming source consumer.
FlinkKafkaConsumer(Pattern subscriptionPattern, KafkaDeserializationSchema<T> deserializer, Properties props) Creates a new Kafka streaming source consumer.
FlinkKafkaConsumer(String topic, KafkaDeserializationSchema<T> deserializer, Properties props) Creates a new Kafka streaming source consumer.
FlinkKafkaConsumer010(List<String> topics, KafkaDeserializationSchema<T> deserializer, Properties props) Creates a new Kafka streaming source consumer for Kafka 0.10.x
FlinkKafkaConsumer010(Pattern subscriptionPattern, KafkaDeserializationSchema<T> deserializer, Properties props) Creates a new Kafka streaming source consumer for Kafka 0.10.x.
FlinkKafkaConsumer010(String topic, KafkaDeserializationSchema<T> deserializer, Properties props) Creates a new Kafka streaming source consumer for Kafka 0.10.x
FlinkKafkaConsumer011(List<String> topics, KafkaDeserializationSchema<T> deserializer, Properties props) Creates a new Kafka streaming source consumer for Kafka 0.11.x
FlinkKafkaConsumer011(Pattern subscriptionPattern, KafkaDeserializationSchema<T> deserializer, Properties props) Creates a new Kafka streaming source consumer for Kafka 0.11.x.
FlinkKafkaConsumer011(String topic, KafkaDeserializationSchema<T> deserializer, Properties props) Creates a new Kafka streaming source consumer for Kafka 0.11.x
FlinkKafkaConsumerBase(List<String> topics, Pattern topicPattern, KafkaDeserializationSchema<T> deserializer, long discoveryIntervalMillis, boolean useMetrics) Base constructor.

Uses of KafkaDeserializationSchema in org.apache.flink.streaming.connectors.kafka.internal

Constructors in org.apache.flink.streaming.connectors.kafka.internal with parameters of type KafkaDeserializationSchema

Constructor and Description
Kafka010Fetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<WatermarkStrategy<T>> watermarkStrategy, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics, FlinkConnectorRateLimiter rateLimiter)
KafkaFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<WatermarkStrategy<T>> watermarkStrategy, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics)
KafkaShuffleFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<WatermarkStrategy<T>> watermarkStrategy, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics, TypeSerializer<T> typeSerializer, int producerParallelism)

Uses of KafkaDeserializationSchema in org.apache.flink.streaming.connectors.kafka.internals

Classes in org.apache.flink.streaming.connectors.kafka.internals that implement KafkaDeserializationSchema

Modifier and Type	Class and Description
class	KafkaDeserializationSchemaWrapper<T> A simple wrapper for using the DeserializationSchema with the KafkaDeserializationSchema interface.

Uses of KafkaDeserializationSchema in org.apache.flink.streaming.util.serialization

Subinterfaces of KafkaDeserializationSchema in org.apache.flink.streaming.util.serialization

Modifier and Type	Interface and Description
interface	KeyedDeserializationSchema<T> Deprecated. Use KafkaDeserializationSchema.

Classes in org.apache.flink.streaming.util.serialization that implement KafkaDeserializationSchema

Modifier and Type	Class and Description
class	JSONKeyValueDeserializationSchema DeserializationSchema that deserializes a JSON String into an ObjectNode.
class	TypeInformationKeyValueSerializationSchema<K,V> A serialization and deserialization schema for Key Value Pairs that uses Flink's serialization stack to transform typed from and to byte arrays.