Package org.apache.kafka.streams.kstream
Class WindowedSerdes
- java.lang.Object
-
- org.apache.kafka.streams.kstream.WindowedSerdes
-
public class WindowedSerdes extends Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
WindowedSerdes.SessionWindowedSerde<T>
static class
WindowedSerdes.TimeWindowedSerde<T>
-
Constructor Summary
Constructors Constructor Description WindowedSerdes()
-
Method Summary
All Methods Static Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static <T> Serde<Windowed<T>>
sessionWindowedSerdeFrom(Class<T> type)
Construct aSessionWindowedSerde
object for the specified inner class type.static <T> Serde<Windowed<T>>
timeWindowedSerdeFrom(Class<T> type)
Deprecated.static <T> Serde<Windowed<T>>
timeWindowedSerdeFrom(Class<T> type, long windowSize)
Construct aTimeWindowedSerde
object to deserialize changelog topic for the specified inner class type and window size.
-
-
-
Method Detail
-
timeWindowedSerdeFrom
@Deprecated public static <T> Serde<Windowed<T>> timeWindowedSerdeFrom(Class<T> type)
Deprecated.Construct aTimeWindowedSerde
object for the specified inner class type.
-
timeWindowedSerdeFrom
public static <T> Serde<Windowed<T>> timeWindowedSerdeFrom(Class<T> type, long windowSize)
Construct aTimeWindowedSerde
object to deserialize changelog topic for the specified inner class type and window size.
-
-