kafka-streams-internals-NamedCache.adoc

NamedCache

NamedCache is…​FIXME

NamedCache is created exclusively when ThreadCache is requested to get or create a new named cache by namespace.

Creating NamedCache Instance

NamedCache takes the following to be created:

• Name

• StreamsMetricsImpl

NamedCache initializes the internal properties.

NamedCacheMetrics — Performance Metrics of NamedCache

NamedCache uses the following performance metrics…​FIXME

setListener Method

void setListener(
  ThreadCache.DirtyEntryFlushListener listener)

setListener simply sets the listener internal registry to be the ThreadCache.DirtyEntryFlushListener.

Note	setListener is used exclusively when ThreadCache is requested to register a DirtyEntryFlushListener for a namespace.

evict Method

void evict()

evict…​FIXME

Note	evict is used exclusively when ThreadCache is requested to maybeEvict a namespace

close Method

void close()

close…​FIXME

Note	close is used when…​FIXME

flush Method

void flush() // (1)
// Private API
void flush(LRUNode evicted)

1. Uses null for the evicted LRUNode

flush…​FIXME

Note	flush is used when…​FIXME

Internal Properties

Name	Description
listener	ThreadCache.DirtyEntryFlushListener Initialized in setListener Removed (nullified) in close Used exclusively when flush an evicted LRUNode