Interface WindowPartitionCache<K,V>

Type Parameters:
K - the key type
V - the value type
All Known Implementing Classes:
SimpleWindowPartitionCache

public interface WindowPartitionCache<K,V>
A loading cache abstraction for caching WindowState.WindowPartition.
  • Method Details

    • 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 a ConcurrentMap view 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