Class WindowedSerdes.TimeWindowedSerde<T>

java.lang.Object
org.apache.kafka.common.serialization.Serdes.WrapperSerde<Windowed<T>>
org.apache.kafka.streams.kstream.WindowedSerdes.TimeWindowedSerde<T>
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.common.serialization.Serde<Windowed<T>>
Enclosing class:
WindowedSerdes
public static class WindowedSerdes.TimeWindowedSerde<T>extends org.apache.kafka.common.serialization.Serdes.WrapperSerde<Windowed<T>>

  • Constructor Details

    • TimeWindowedSerde

      public TimeWindowedSerde()

    • TimeWindowedSerde

      public TimeWindowedSerde(org.apache.kafka.common.serialization.Serde<T> inner, long windowSize)

  • Method Details