public class SessionWindowedSerializer<T> extends Object implements org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>
Constructor and Description |
---|
SessionWindowedSerializer() |
SessionWindowedSerializer(org.apache.kafka.common.serialization.Serializer<T> inner) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(Map<String,?> configs,
boolean isKey) |
byte[] |
serialize(String topic,
Windowed<T> data) |
byte[] |
serializeBaseKey(String topic,
Windowed<T> data) |
public SessionWindowedSerializer()
public SessionWindowedSerializer(org.apache.kafka.common.serialization.Serializer<T> inner)