org.apache.beam.sdk.io.kafka

Interface DeserializerProvider<T>

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

ConfluentSchemaRegistryDeserializerProvider

@Experimental(value=SOURCE_SINK)
public interface DeserializerProvider<T>
extends java.io.Serializable

Provides a configured Deserializer instance and its associated Coder.

Method Summary

Modifier and Type	Method and Description
Coder<T>	getCoder(CoderRegistry coderRegistry)
Deserializer<T>	getDeserializer(java.util.Map<java.lang.String,?> configs, boolean isKey)

Method Detail

getDeserializer

Deserializer<T> getDeserializer(java.util.Map<java.lang.String,?> configs,
                                boolean isKey)

getCoder

Coder<T> getCoder(CoderRegistry coderRegistry)