Package org.apache.kafka.streams.kstream.internals

Class WrappingNullableUtils

java.lang.Object

org.apache.kafka.streams.kstream.internals.WrappingNullableUtils

public class WrappingNullableUtils
extends Object

If a component's serdes are Wrapping serdes, then they require a little extra setup to be fully initialized at run time.

Constructor Summary

Constructors

Constructor	Description
WrappingNullableUtils()

Method Summary

Modifier and Type	Method	Description
static <T> void	initNullableDeserializer(Deserializer<T> specificDeserializer, Deserializer<?> contextKeyDeserializer, Deserializer<?> contextValueDeserializer)
static <T> void	initNullableSerializer(Serializer<T> specificSerializer, Serializer<?> contextKeySerializer, Serializer<?> contextValueSerializer)
static <K> Deserializer<K>	prepareKeyDeserializer(Deserializer<K> specificDeserializer, Deserializer<?> contextKeyDeserializer, Deserializer<?> contextValueDeserializer)
static <K> Serde<K>	prepareKeySerde(Serde<K> specificSerde, Serde<?> keySerde, Serde<?> valueSerde)
static <K> Serializer<K>	prepareKeySerializer(Serializer<K> specificSerializer, Serializer<?> contextKeySerializer, Serializer<?> contextValueSerializer)
static <V> Deserializer<V>	prepareValueDeserializer(Deserializer<V> specificDeserializer, Deserializer<?> contextKeyDeserializer, Deserializer<?> contextValueDeserializer)
static <V> Serde<V>	prepareValueSerde(Serde<V> specificSerde, Serde<?> keySerde, Serde<?> valueSerde)
static <V> Serializer<V>	prepareValueSerializer(Serializer<V> specificSerializer, Serializer<?> contextKeySerializer, Serializer<?> contextValueSerializer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WrappingNullableUtils

public WrappingNullableUtils()

Method Detail

prepareKeyDeserializer

public static <K> Deserializer<K> prepareKeyDeserializer(Deserializer<K> specificDeserializer,
                                                         Deserializer<?> contextKeyDeserializer,
                                                         Deserializer<?> contextValueDeserializer)

prepareValueDeserializer

public static <V> Deserializer<V> prepareValueDeserializer(Deserializer<V> specificDeserializer,
                                                           Deserializer<?> contextKeyDeserializer,
                                                           Deserializer<?> contextValueDeserializer)

prepareKeySerializer

public static <K> Serializer<K> prepareKeySerializer(Serializer<K> specificSerializer,
                                                     Serializer<?> contextKeySerializer,
                                                     Serializer<?> contextValueSerializer)

prepareValueSerializer

public static <V> Serializer<V> prepareValueSerializer(Serializer<V> specificSerializer,
                                                       Serializer<?> contextKeySerializer,
                                                       Serializer<?> contextValueSerializer)

prepareKeySerde

public static <K> Serde<K> prepareKeySerde(Serde<K> specificSerde,
                                           Serde<?> keySerde,
                                           Serde<?> valueSerde)

prepareValueSerde

public static <V> Serde<V> prepareValueSerde(Serde<V> specificSerde,
                                             Serde<?> keySerde,
                                             Serde<?> valueSerde)

initNullableSerializer

public static <T> void initNullableSerializer(Serializer<T> specificSerializer,
                                              Serializer<?> contextKeySerializer,
                                              Serializer<?> contextValueSerializer)

initNullableDeserializer

public static <T> void initNullableDeserializer(Deserializer<T> specificDeserializer,
                                                Deserializer<?> contextKeyDeserializer,
                                                Deserializer<?> contextValueDeserializer)