Package org.apache.kafka.streams.kstream

Class TimeWindowedDeserializer<T>

java.lang.Object

org.apache.kafka.streams.kstream.TimeWindowedDeserializer<T>

All Implemented Interfaces:

Closeable, AutoCloseable, Deserializer<Windowed<T>>

public class TimeWindowedDeserializer<T>
extends Object
implements Deserializer<Windowed<T>>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	WINDOW_SIZE_MS_CONFIG	Sets window size for the deserializer in order to calculate window end times.
static final String	WINDOWED_INNER_DESERIALIZER_CLASS	Default deserializer for the inner deserializer class of a windowed record.

Constructor Summary

Constructors

Constructor	Description
TimeWindowedDeserializer()
TimeWindowedDeserializer(Deserializer<T> inner, Long windowSize)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.kafka.common.serialization.Deserializer

deserialize, deserialize

Field Details

WINDOW_SIZE_MS_CONFIG

public static final String WINDOW_SIZE_MS_CONFIG

Sets window size for the deserializer in order to calculate window end times.

See Also:

• Constant Field Values

WINDOWED_INNER_DESERIALIZER_CLASS

public static final String WINDOWED_INNER_DESERIALIZER_CLASS

Default deserializer for the inner deserializer class of a windowed record. Must implement the Serde interface.

See Also:

• Constant Field Values

Constructor Details

TimeWindowedDeserializer

public TimeWindowedDeserializer()

TimeWindowedDeserializer

public TimeWindowedDeserializer(Deserializer<T> inner,
 Long windowSize)

Method Details

getWindowSize

public Long getWindowSize()

configure

public void configure(Map<String,?> configs,
 boolean isKey)

Description copied from interface: Deserializer

Configure this class.

Specified by:

configure in interface Deserializer<T>

Parameters:

configs - configs in key/value pairs

isKey - whether the deserializer is used for the key or the value

deserialize

public Windowed<T> deserialize(String topic,
 byte[] data)

Description copied from interface: Deserializer

Deserialize a record value from a byte array into a value or object.

It is recommended to deserialize a null byte array to a null object.

Specified by:

deserialize in interface Deserializer<T>

Parameters:

topic - topic associated with the data

data - serialized bytes; may be null

Returns:

deserialized typed data; may be null

close

public void close()

Description copied from interface: Deserializer

Close this deserializer.

This method must be idempotent as it may be called multiple times.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Deserializer<T>

setIsChangelogTopic

public void setIsChangelogTopic(boolean isChangelogTopic)