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 key, long earliestSessionEndTime, long latestSessionStartTime) Fetch any sessions with the matching key and the sessions end is &le earliestEndTime and the sessions start is &ge latestStartTime
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

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 &le earliestEndTime and the sessions start is &ge latestStartTime

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