org.apache.kafka.streams.state

Interface ReadOnlySessionStore<K,AGG>

Type Parameters:

K - the key type

AGG - the aggregated value type

All Known Subinterfaces:

SessionStore<K,AGG>

@InterfaceStability.Unstable
public interface ReadOnlySessionStore<K,AGG>

A session store that only supports read operations. Implementations should be thread-safe as concurrent reads and writes are expected.

Method Summary

Methods

Modifier and Type	Method and Description
KeyValueIterator<Windowed<K>,AGG>	fetch(K key) Retrieve all aggregated sessions for the provided key

Method Detail

fetch

KeyValueIterator<Windowed<K>,AGG> fetch(K key)

Retrieve all aggregated sessions for the provided key

Parameters:

key - record key to find aggregated session values for

Returns:

KeyValueIterator containing all sessions for the provided key.