MCPcopy
hub / github.com/apache/kafka / put

Method put

clients/src/main/java/org/apache/kafka/common/cache/Cache.java:37–37  ·  view source on GitHub ↗

Insert an entry into the cache. @param key the key to insert @param value the value to insert

(K key, V value)

Source from the content-addressed store, hash-verified

35 * @param value the value to insert
36 */
37 void put(K key, V value);
38
39 /**
40 * Manually invalidate a key, clearing its entry from the cache.

Implementers 7

SharePartitionCachecore/src/main/java/kafka/server/share/
TimelineHashMapserver-common/src/main/java/org/apache
PCollectionsImmutableMapserver-common/src/main/java/org/apache
NamedCachestreams/src/main/java/org/apache/kafka
LRUCacheclients/src/main/java/org/apache/kafka
SynchronizedCacheclients/src/main/java/org/apache/kafka
CopyOnWriteMapclients/src/main/java/org/apache/kafka

Calls

no outgoing calls