ChangeLoggingSessionBytesStore

ChangeLoggingSessionBytesStore is a SessionStore that uses Kafka Bytes (immutable byte arrays) for keys.

ChangeLoggingSessionBytesStore is created exclusively when SessionStoreBuilder is requested to build a MeteredSessionStore (with logging enabled).

ChangeLoggingSessionBytesStore takes a SessionStore when created.

Table 1. ChangeLoggingSessionBytesStore’s Internal Properties (e.g. Registries, Counters and Flags)
Name Description

changeLogger

StoreChangeLogger

Used when…​FIXME

innerStateSerde

StateSerdes

Used when…​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 Key — put Method

void put(final Windowed<Bytes> sessionKey, final byte[] aggregate)
Note
 put is part of SessionStore Contract to store an aggregated value for a session key.

put requests the SessionStore to store the aggregated value for the given session key.

In the end, put…​FIXME

results matching ""

    No results matching ""