public class TimeWindowedDeserializer<T> extends Object implements Deserializer<Windowed<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 and Description |
---|
TimeWindowedDeserializer() |
TimeWindowedDeserializer(Deserializer<T> inner) |
TimeWindowedDeserializer(Deserializer<T> inner,
long windowSize) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close this deserializer.
|
void |
configure(Map<String,?> configs,
boolean isKey)
Configure this class.
|
Windowed<T> |
deserialize(String topic,
byte[] data)
Deserialize a record value from a byte array into a value or object.
|
Long |
getWindowSize() |
void |
setIsChangelogTopic(boolean isChangelogTopic) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
deserialize
public TimeWindowedDeserializer()
public TimeWindowedDeserializer(Deserializer<T> inner)
public TimeWindowedDeserializer(Deserializer<T> inner, long windowSize)
public Long getWindowSize()
public void configure(Map<String,?> configs, boolean isKey)
Deserializer
configure
in interface Deserializer<Windowed<T>>
configs
- configs in key/value pairsisKey
- whether is for key or valuepublic Windowed<T> deserialize(String topic, byte[] data)
Deserializer
deserialize
in interface Deserializer<Windowed<T>>
topic
- topic associated with the datadata
- serialized bytes; may be null; implementations are recommended to handle null by returning a value or null rather than throwing an exception.public void close()
Deserializer
This method must be idempotent as it may be called multiple times.
close
in interface Closeable
close
in interface AutoCloseable
close
in interface Deserializer<Windowed<T>>
public void setIsChangelogTopic(boolean isChangelogTopic)