org.apache.kafka.streams.state

Interface WindowStore<K,V>

Type Parameters:

K - Type of keys

V - Type of values

All Superinterfaces:

ReadOnlyWindowStore<K,V>, StateStore

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

A windowed store interface extending StateStore.

Method Summary

Methods

Modifier and Type	Method and Description
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, isOpen, name, persistent

Methods inherited from interface org.apache.kafka.streams.state.ReadOnlyWindowStore

fetch

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