org.apache.kafka.streams.state

Interface SessionStore<K,AGG>

Type Parameters:

K - type of the record keys

AGG - type of the aggregated values

All Superinterfaces:

ReadOnlySessionStore<K,AGG>, StateStore

public interface SessionStore<K,AGG>
extends StateStore, ReadOnlySessionStore<K,AGG>

Interface for storing the aggregated values of sessions

Method Summary

Methods

Modifier and Type	Method and Description
KeyValueIterator<Windowed<K>,AGG>	findSessions(K keyFrom, K keyTo, long earliestSessionEndTime, long latestSessionStartTime) Fetch any sessions in the given range of keys and the sessions end is ≥ earliestSessionEndTime and the sessions start is ≤ latestSessionStartTime
KeyValueIterator<Windowed<K>,AGG>	findSessions(K key, long earliestSessionEndTime, long latestSessionStartTime) Fetch any sessions with the matching key and the sessions end is ≥ earliestSessionEndTime and the sessions start is ≤ latestSessionStartTime
void	put(Windowed<K> sessionKey, AGG aggregate) Write the aggregated value for the provided key to the store
void	remove(Windowed<K> sessionKey) Remove the session aggregated with provided Windowed key from the store

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.ReadOnlySessionStore

fetch, fetch

Method Detail

findSessions

KeyValueIterator<Windowed<K>,AGG> findSessions(K key,
                                             long earliestSessionEndTime,
                                             long latestSessionStartTime)

Fetch any sessions with the matching key and the sessions end is ≥ earliestSessionEndTime and the sessions start is ≤ latestSessionStartTime

Parameters:

key - the key to return sessions for

earliestSessionEndTime -

Returns:

iterator of sessions with the matching key and aggregated values

findSessions

KeyValueIterator<Windowed<K>,AGG> findSessions(K keyFrom,
                                             K keyTo,
                                             long earliestSessionEndTime,
                                             long latestSessionStartTime)

Fetch any sessions in the given range of keys and the sessions end is ≥ earliestSessionEndTime and the sessions start is ≤ latestSessionStartTime

Parameters:

keyFrom - The first key that could be in the range

keyTo - The last key that could be in the range

earliestSessionEndTime -

Returns:

iterator of sessions with the matching keys and aggregated values

remove

void remove(Windowed<K> sessionKey)

Remove the session aggregated with provided Windowed key from the store

Parameters:

sessionKey - key of the session to remove

put

void put(Windowed<K> sessionKey,
       AGG aggregate)

Write the aggregated value for the provided key to the store

Parameters:

sessionKey - key of the session to write

aggregate - the aggregated value for the session