public class SessionWindowedSerializer<T> extends java.lang.Object implements WindowedSerializer<T>
StreamsConfig.DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS
or
StreamsConfig.DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS
if the no-arg constructor is called and hence it is not passed during initialization.Constructor and Description |
---|
SessionWindowedSerializer() |
SessionWindowedSerializer(org.apache.kafka.common.serialization.Serializer<T> inner) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(java.util.Map<java.lang.String,?> configs,
boolean isKey) |
byte[] |
serialize(java.lang.String topic,
Windowed<T> data) |
byte[] |
serializeBaseKey(java.lang.String topic,
Windowed<T> data) |
public SessionWindowedSerializer()
public SessionWindowedSerializer(org.apache.kafka.common.serialization.Serializer<T> inner)
public void configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
public void close()
public byte[] serializeBaseKey(java.lang.String topic, Windowed<T> data)
serializeBaseKey
in interface WindowedSerializer<T>