public class TimeWindowedSerializer<T> extends Object implements org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>
| Constructor and Description |
|---|
TimeWindowedSerializer() |
TimeWindowedSerializer(Serializer<T> inner) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close this serializer.
|
void |
configure(Map<String,?> configs,
boolean isKey)
Configure this class.
|
byte[] |
serialize(String topic,
Windowed<T> data)
Convert
data into a byte array. |
byte[] |
serializeBaseKey(String topic,
Windowed<T> data) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitserializepublic TimeWindowedSerializer()
public TimeWindowedSerializer(Serializer<T> inner)
public void configure(Map<String,?> configs, boolean isKey)
Serializerconfigure in interface Serializer<Windowed<T>>configs - configs in key/value pairsisKey - whether is for key or valuepublic byte[] serialize(String topic, Windowed<T> data)
Serializerdata into a byte array.serialize in interface Serializer<Windowed<T>>topic - topic associated with datadata - typed datapublic void close()
SerializerThis method must be idempotent as it may be called multiple times.
close in interface Closeableclose in interface AutoCloseableclose in interface Serializer<Windowed<T>>