Package org.apache.kafka.streams.state.internals

Class MemoryNavigableLRUCache

java.lang.Object

org.apache.kafka.streams.state.internals.MemoryLRUCache

org.apache.kafka.streams.state.internals.MemoryNavigableLRUCache

All Implemented Interfaces:

StateStore, KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>, ReadOnlyKeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>

public class MemoryNavigableLRUCache
extends MemoryLRUCache

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.kafka.streams.state.internals.MemoryLRUCache

MemoryLRUCache.EldestEntryRemovalListener

Field Summary

Fields inherited from class org.apache.kafka.streams.state.internals.MemoryLRUCache

map

Constructor Summary

Constructors

Constructor	Description
MemoryNavigableLRUCache(String name, int maxCacheSize)

Method Summary

Modifier and Type	Method	Description
KeyValueIterator<org.apache.kafka.common.utils.Bytes,byte[]>	all()	Return an iterator over all keys in this store.
KeyValueIterator<org.apache.kafka.common.utils.Bytes,byte[]>	range(org.apache.kafka.common.utils.Bytes from, org.apache.kafka.common.utils.Bytes to)	Get an iterator over a given range of keys.

Methods inherited from class org.apache.kafka.streams.state.internals.MemoryLRUCache

approximateNumEntries, close, delete, flush, get, init, isOpen, name, persistent, put, putAll, putIfAbsent, size

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MemoryNavigableLRUCache

public MemoryNavigableLRUCache(String name,
                               int maxCacheSize)

Method Detail

range

public KeyValueIterator<org.apache.kafka.common.utils.Bytes,byte[]> range(org.apache.kafka.common.utils.Bytes from,
                                                                                org.apache.kafka.common.utils.Bytes to)

Description copied from interface: ReadOnlyKeyValueStore

Get an iterator over a given range of keys. This iterator must be closed after use. The returned iterator must be safe from ConcurrentModificationExceptions and must not return null values. No ordering guarantees are provided.

Specified by:

range in interface ReadOnlyKeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>

Overrides:

range in class MemoryLRUCache

Parameters:

from - The first key that could be in the range

to - The last key that could be in the range

Returns:

The iterator for this range.

all

public KeyValueIterator<org.apache.kafka.common.utils.Bytes,byte[]> all()

Description copied from interface: ReadOnlyKeyValueStore

Return an iterator over all keys in this store. This iterator must be closed after use. The returned iterator must be safe from ConcurrentModificationExceptions and must not return null values. No ordering guarantees are provided.

Specified by:

all in interface ReadOnlyKeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>

Overrides:

all in class MemoryLRUCache

Returns:

An iterator of all key/value pairs in the store.