Interface WindowPartitionCache<K,V>
-
- Type Parameters:
K- the key typeV- the value type
- All Known Implementing Classes:
SimpleWindowPartitionCache
public interface WindowPartitionCache<K,V>A loading cache abstraction for cachingWindowState.WindowPartition.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interfaceWindowPartitionCache.Builder<K,V>Builder interface forWindowPartitionCache.static interfaceWindowPartitionCache.CacheLoader<K,V>The interface for loading entires into the cache.static classWindowPartitionCache.RemovalCauseThe reason why an enrty got evicted from the cache.static interfaceWindowPartitionCache.RemovalListener<K,V>A callback interface for handling removal of events from the cache.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ConcurrentMap<K,V>asMap()Return aConcurrentMapview of the current entries in the cache.Vget(K key)Get value from the cache or load the value.voidinvalidate(K key)Invalidate an entry from the cache.VpinAndGet(K key)Get value from the cache or load the value pinning it so that the entry will never get evicted.booleanunpin(K key)Unpin an entry from the cache so that it can be a candidate for eviction.
-
-
-
Method Detail
-
get
V get(K key)
Get value from the cache or load the value.- Parameters:
key- the key- Returns:
- the value
-
pinAndGet
V pinAndGet(K key)
Get value from the cache or load the value pinning it so that the entry will never get evicted.- Parameters:
key- the key- Returns:
- the value
-
unpin
boolean unpin(K key)
Unpin an entry from the cache so that it can be a candidate for eviction.- Parameters:
key- the key- Returns:
- true if the entry was unpinned, false otherwise
-
asMap
ConcurrentMap<K,V> asMap()
Return aConcurrentMapview of the current entries in the cache.- Returns:
- the map of key-values currently cached.
-
invalidate
void invalidate(K key)
Invalidate an entry from the cache.- Parameters:
key- the key
-
-