SessionStore

SessionStore is the contract of state stores that FIXME.

package org.apache.kafka.streams.state;

interface SessionStore<K, AGG> extends StateStore, ReadOnlySessionStore<K, AGG> {
  KeyValueIterator<Windowed<K>, AGG> findSessions(final K key, long earliestSessionEndTime, final long latestSessionStartTime);
  KeyValueIterator<Windowed<K>, AGG> findSessions(final K keyFrom, final K keyTo, long earliestSessionEndTime, final long latestSessionStartTime);
  void put(final Windowed<K> sessionKey, final AGG aggregate);
  void remove(final Windowed<K> sessionKey);
}
Table 1. SessionStore Contract
Method Description

findSessions

Used when…​FIXME

put

Storing an aggregated value for a session key

Used when:

remove

Used when…​FIXME

Table 2. SessionStores
SessionStore Description

CachingSessionStore

RocksDBSessionStore

ChangeLoggingSessionBytesStore

MeteredSessionStore

results matching ""

    No results matching ""