Package org.apache.kafka.streams.state

Interface SessionStoreWithHeaders<K,AGG>

Type Parameters:
K - type of the record keys
AGG - type of the aggregated values
All Superinterfaces:
ReadOnlySessionStore<K,AggregationWithHeaders<AGG>>, SessionStore<K,AggregationWithHeaders<AGG>>, StateStore
public interface SessionStoreWithHeaders<K,AGG> extends StateStore, SessionStore<K,AggregationWithHeaders<AGG>>
Interface for storing the aggregated values of sessions along with their record headers.

The key is internally represented as Windowed<K> that comprises the plain key and the Window that represents window start- and end-timestamp.

If two sessions are merged, a new session with new start- and end-timestamp must be inserted into the store while the two old sessions must be deleted.