Package org.apache.kafka.streams.kstream
Class WindowedSerdes
- java.lang.Object
-
- org.apache.kafka.streams.kstream.WindowedSerdes
-
public class WindowedSerdes extends java.lang.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 Modifier and Type Method Description static <T> org.apache.kafka.common.serialization.Serde<Windowed<T>>
sessionWindowedSerdeFrom(java.lang.Class<T> type)
Construct aSessionWindowedSerde
object for the specified inner class type.static <T> org.apache.kafka.common.serialization.Serde<Windowed<T>>
timeWindowedSerdeFrom(java.lang.Class<T> type)
Construct aTimeWindowedSerde
object for the specified inner class type.
-
-
-
Method Detail
-
timeWindowedSerdeFrom
public static <T> org.apache.kafka.common.serialization.Serde<Windowed<T>> timeWindowedSerdeFrom(java.lang.Class<T> type)
Construct aTimeWindowedSerde
object for the specified inner class type.
-
sessionWindowedSerdeFrom
public static <T> org.apache.kafka.common.serialization.Serde<Windowed<T>> sessionWindowedSerdeFrom(java.lang.Class<T> type)
Construct aSessionWindowedSerde
object for the specified inner class type.
-
-