WindowedSerdes (streams 8.0.4-ce API)

java.lang.Object

org.apache.kafka.streams.kstream.WindowedSerdes

public class WindowedSerdesextends 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.