kafka-streams-internals-MeteredSessionStore.adoc

MeteredSessionStore

MeteredSessionStore is a SessionStore that…​FIXME

Initialize State Store — init Method

void init(final ProcessorContext context, final StateStore root)

Note	init is part of…​FIXME

init…​FIXME

Storing Aggregated Value for Session — put Method

void put(final Windowed<K> sessionKey, final V aggregate)

Note	put is part of SessionStore Contract to store an aggregated value for a session.

put…​FIXME

Removing Aggregated Value for Session — remove Method

void remove(final Windowed<K> sessionKey)

Note	remove is part of SessionStore Contract to remove an aggregated value for a session.

remove…​FIXME