java.io.Closeable
, java.lang.AutoCloseable
, Serializer<T>
, org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>
public class TimeWindowedSerializer<T>
extends java.lang.Object
implements org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>
StreamsConfig.DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS
or
StreamsConfig.DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS
if the no-arg constructor is called and hence it is not passed during initialization.Constructor | Description |
---|---|
TimeWindowedSerializer() |
|
TimeWindowedSerializer(Serializer<T> inner) |
Modifier and Type | Method | Description |
---|---|---|
void |
close() |
Close this serializer.
|
void |
configure(java.util.Map<java.lang.String,?> configs,
boolean isKey) |
Configure this class.
|
byte[] |
serialize(java.lang.String topic,
Windowed<T> data) |
Convert
data into a byte array. |
byte[] |
serializeBaseKey(java.lang.String topic,
Windowed<T> data) |
public TimeWindowedSerializer()
public TimeWindowedSerializer(Serializer<T> inner)
public void configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
Serializer
configure
in interface Serializer<T>
configs
- configs in key/value pairsisKey
- whether is for key or valuepublic byte[] serialize(java.lang.String topic, Windowed<T> data)
Serializer
data
into a byte array.serialize
in interface Serializer<T>
topic
- topic associated with datadata
- typed datapublic void close()
Serializer
close
in interface java.lang.AutoCloseable
close
in interface java.io.Closeable
close
in interface Serializer<T>