public class SessionWindowedDeserializer<T> extends Object implements org.apache.kafka.common.serialization.Deserializer<Windowed<T>>
| Constructor and Description |
|---|
SessionWindowedDeserializer() |
SessionWindowedDeserializer(org.apache.kafka.common.serialization.Deserializer<T> inner) |
| Modifier and Type | Method and Description |
|---|---|
void | close() |
void | configure(Map<String,?> configs, boolean isKey) |
Windowed<T> | deserialize(String topic, byte[] data) |
public SessionWindowedDeserializer()
public SessionWindowedDeserializer(org.apache.kafka.common.serialization.Deserializer<T> inner)