Package org.apache.kafka.streams.kstream
Class WindowedSerdes
java.lang.Object
org.apache.kafka.streams.kstream.WindowedSerdes
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic class
static class
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> org.apache.kafka.common.serialization.Serde
<Windowed<T>> sessionWindowedSerdeFrom
(Class<T> type) Construct aSessionWindowedSerde
object for the specified inner class type.static <T> org.apache.kafka.common.serialization.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.
-
Constructor Details
-
WindowedSerdes
public WindowedSerdes()
-
-
Method Details
-
timeWindowedSerdeFrom
public static <T> org.apache.kafka.common.serialization.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. -
sessionWindowedSerdeFrom
public static <T> org.apache.kafka.common.serialization.Serde<Windowed<T>> sessionWindowedSerdeFrom(Class<T> type) Construct aSessionWindowedSerde
object for the specified inner class type.
-