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);
}