Class WindowedSerdes.SessionWindowedSerde<T>

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

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

    • SessionWindowedSerde

      public SessionWindowedSerde()
    • SessionWindowedSerde

      public SessionWindowedSerde​(Serde<T> inner)