Interface WindowedSerializer<T>
-
- All Superinterfaces:
java.lang.AutoCloseable
,java.io.Closeable
,org.apache.kafka.common.serialization.Serializer<Windowed<T>>
- All Known Implementing Classes:
SessionWindowedSerializer
,TimeWindowedSerializer
public interface WindowedSerializer<T> extends org.apache.kafka.common.serialization.Serializer<Windowed<T>>
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description byte[]
serializeBaseKey(java.lang.String topic, Windowed<T> data)
-