kafka-streams-internals-CachingSessionStore.adoc

CachingSessionStore

CachingSessionStore is…​FIXME

Initialize State Store — init Method

void init(final ProcessorContext context, final StateStore root)

Note	init is part of…​FIXME

init…​FIXME

remove Method

void remove(final Windowed<Bytes> sessionKey)

Note	remove is part of SessionStore Contract to…​FIXME.

remove…​FIXME

putAndMaybeForward Internal Method

void putAndMaybeForward(final ThreadCache.DirtyEntry entry, final InternalProcessorContext context)

putAndMaybeForward…​FIXME

Note	putAndMaybeForward is used when…​FIXME

Closing State Store — close Method

void close()

Note	close is part of…​FIXME

close…​FIXME