public class WindowedSerdes extends Object
| Modifier and Type | Class and Description |
|---|---|
static class | WindowedSerdes.SessionWindowedSerde<T> |
static class | WindowedSerdes.TimeWindowedSerde<T> |
| Constructor and Description |
|---|
WindowedSerdes() |
| Modifier and Type | Method and Description |
|---|---|
static <T> org.apache.kafka.common.serialization.Serde<Windowed<T>> | sessionWindowedSerdeFrom(Class<T> type)Construct a SessionWindowedSerde object for the specified inner class type. |
static <T> org.apache.kafka.common.serialization.Serde<Windowed<T>> | timeWindowedSerdeFrom(Class<T> type)Deprecated. |
static <T> org.apache.kafka.common.serialization.Serde<Windowed<T>> | timeWindowedSerdeFrom(Class<T> type, long windowSize)Construct a TimeWindowedSerde object to deserialize changelog topic for the specified inner class type and window size. |
@Deprecated public static <T> org.apache.kafka.common.serialization.Serde<Windowed<T>> timeWindowedSerdeFrom(Class<T> type)
TimeWindowedSerde object for the specified inner class type.public static <T> org.apache.kafka.common.serialization.Serde<Windowed<T>> timeWindowedSerdeFrom(Class<T> type, long windowSize)
TimeWindowedSerde object to deserialize changelog topic for the specified inner class type and window size.