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)