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

Modifier and Type	Method	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, long windowSize)	Construct a TimeWindowedSerde object to deserialize changelog topic for the specified inner class type and window size.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 a TimeWindowedSerde 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 a SessionWindowedSerde object for the specified inner class type.