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, Serde<Windowed<T>>
Enclosing class:
WindowedSerdes

public static class WindowedSerdes.TimeWindowedSerde<T> extends Serdes.WrapperSerde<Windowed<T>>
  • Constructor Details

    • TimeWindowedSerde

      public TimeWindowedSerde()
    • TimeWindowedSerde

      @Deprecated public TimeWindowedSerde(Serde<T> inner)
      Deprecated.
    • TimeWindowedSerde

      public TimeWindowedSerde(Serde<T> inner, long windowSize)
  • Method Details