org.apache.kafka.streams.state

Interface WindowStore<K,V>

Type Parameters:

K - Type of keys

V - Type of values

All Superinterfaces:

StateStore

@InterfaceStability.Unstable
public interface WindowStore<K,V>
extends StateStore

A windowed store interface extending StateStore.

Method Summary

Methods

Modifier and Type	Method and Description
WindowStoreIterator<V>	fetch(K key, long timeFrom, long timeTo) Get all the key-value pairs with the given key and the time range from all the existing windows.
void	put(K key, V value) Put a key-value pair with the current wall-clock time as the timestamp into the corresponding window
void	put(K key, V value, long timestamp) Put a key-value pair with the given timestamp into the corresponding window

Methods inherited from interface org.apache.kafka.streams.processor.StateStore

close, flush, init, name, persistent

Method Detail

put

void put(K key,
       V value)

Put a key-value pair with the current wall-clock time as the timestamp into the corresponding window

put

void put(K key,
       V value,
       long timestamp)

Put a key-value pair with the given timestamp into the corresponding window

fetch

WindowStoreIterator<V> fetch(K key,
                           long timeFrom,
                           long timeTo)

Get all the key-value pairs with the given key and the time range from all the existing windows.

Returns:

an iterator over key-value pairs <timestamp, value>