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

results matching ""

    No results matching ""