MeteredWindowStore — State Store of WindowStoreBuilder

MeteredWindowStore is a concrete WindowStore that registers the metric sensors (when initialized).

MeteredWindowStore is created exclusively when WindowStoreBuilder is requested for a state store.

Table 1. MeteredWindowStore’s (Latency and Throughput) Metric Sensors
Metric Sensor Name RecordingLevel Description

putTime

put

DEBUG

Latency of put

fetchTime

fetch

DEBUG

Latency of fetch, all and fetchAll

flushTime

flush

DEBUG

Latency of flush

restoreTime

restore

DEBUG

Latency of init

Note
All the metric sensors are at DEBUG recording level so you have to turn them on using metrics.recording.level streams property.

Creating MeteredWindowStore Instance

MeteredWindowStore takes the following when created:

  • WindowStore

  • Scope name for the metrics (aka metric scope)

  • Time

  • Serde<K> for keys

  • Serde<V> for values

MeteredWindowStore initializes the internal registries and counters.

Initializing State Store — init Method

void init(final ProcessorContext context, final StateStore root)
Note
init is part of the StateStore Contract to initializes the state store.

init…​FIXME

init requests the ProcessorContext for the StreamsMetrics and registers the metric sensors.

init…​FIXME

results matching ""

    No results matching ""