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 and Description
static class	WindowedSerdes.SessionWindowedSerde<T>
static class	WindowedSerdes.TimeWindowedSerde<T>

Constructor Summary

Constructors

Constructor and Description
WindowedSerdes()

Method Summary

Modifier and Type	Method and Description
static <T> Serde<Windowed<T>>	sessionWindowedSerdeFrom(java.lang.Class<T> type) Construct a SessionWindowedSerde object for the specified inner class type.
static <T> Serde<Windowed<T>>	timeWindowedSerdeFrom(java.lang.Class<T> type) Construct a TimeWindowedSerde object for the specified inner class type.

Methods inherited from class java.lang.Object

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

Constructor Detail

WindowedSerdes

public WindowedSerdes()

Method Detail

timeWindowedSerdeFrom

public static <T> Serde<Windowed<T>> timeWindowedSerdeFrom(java.lang.Class<T> type)

Construct a TimeWindowedSerde object for the specified inner class type.

sessionWindowedSerdeFrom

public static <T> Serde<Windowed<T>> sessionWindowedSerdeFrom(java.lang.Class<T> type)

Construct a SessionWindowedSerde object for the specified inner class type.