AbstractRocksDBSegmentedBytesStore<S extends Segment> |
|
AbstractStoreBuilder<K,V,T extends StateStore> |
|
BufferKey |
|
BufferValue |
|
CachingKeyValueStore |
|
ChangeLoggingKeyValueBytesStore |
|
ChangeLoggingTimestampedKeyValueBytesStore |
|
CompositeReadOnlyKeyValueStore<K,V> |
|
CompositeReadOnlySessionStore<K,V> |
|
CompositeReadOnlyWindowStore<K,V> |
|
ContextualRecord |
|
DelegatingPeekingKeyValueIterator<K,V> |
Optimized KeyValueIterator used when the same element could be peeked multiple times.
|
GlobalStateStoreProvider |
|
InMemoryKeyValueStore |
|
InMemorySessionBytesStoreSupplier |
|
InMemorySessionStore |
|
InMemoryTimeOrderedKeyValueBuffer<K,V> |
|
InMemoryTimeOrderedKeyValueBuffer.Builder<K,V> |
|
InMemoryWindowBytesStoreSupplier |
|
InMemoryWindowStore |
|
KeyValueIteratorFacade<K,V> |
|
KeyValueStoreBuilder<K,V> |
|
KeyValueToTimestampedKeyValueByteStoreAdapter |
|
Maybe<T> |
A container that may be empty, may contain null, or may contain a value.
|
MemoryLRUCache |
An in-memory LRU cache store based on HashSet and HashMap.
|
MemoryNavigableLRUCache |
|
MeteredKeyValueStore<K,V> |
A Metered KeyValueStore wrapper that is used for recording operation metrics, and hence its
inner KeyValueStore implementation do not need to provide its own metrics collecting functionality.
|
MeteredSessionStore<K,V> |
|
MeteredTimestampedKeyValueStore<K,V> |
A Metered TimestampedKeyValueStore wrapper that is used for recording operation metrics, and hence its
inner KeyValueStore implementation do not need to provide its own metrics collecting functionality.
|
MeteredTimestampedKeyValueStore.RawAndDeserializedValue<ValueType> |
|
MeteredWindowStore<K,V> |
|
Murmur3 |
This class was taken from Hive org.apache.hive.common.util;
https://github.com/apache/hive/blob/master/storage-api/src/java/org/apache/hive/common/util/Murmur3.java
Commit: dffa3a16588bc8e95b9d0ab5af295a74e06ef702
Murmur3 is successor to Murmur2 fast non-crytographic hash algorithms.
|
Murmur3.IncrementalHash32 |
|
OffsetCheckpoint |
This class saves out a map of topic/partition=>offsets to a file.
|
QueryableStoreProvider |
|
ReadOnlyKeyValueStoreFacade<K,V> |
|
ReadOnlyWindowStoreFacade<K,V> |
|
RecordConverters |
|
RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter |
The generic Options class allows users to set all configs on one object if only default column family
is used.
|
RocksDbKeyValueBytesStoreSupplier |
|
RocksDBSegmentedBytesStore |
|
RocksDbSessionBytesStoreSupplier |
|
RocksDBSessionStore |
|
RocksDBStore |
A persistent key-value store based on RocksDB.
|
RocksDBTimestampedSegmentedBytesStore |
|
RocksDBTimestampedStore |
A persistent key-(value-timestamp) store based on RocksDB.
|
RocksDbWindowBytesStoreSupplier |
|
RocksDBWindowStore |
|
SessionKeySchema |
|
SessionStoreBuilder<K,V> |
|
StreamThreadStateStoreProvider |
|
ThreadCache |
An in-memory LRU cache store similar to MemoryLRUCache but byte-based, not
record based
|
TimeOrderedKeyValueBuffer.Eviction<K,V> |
|
TimestampedKeyValueStoreBuilder<K,V> |
|
TimestampedWindowStoreBuilder<K,V> |
|
ValueAndTimestampSerde<V> |
|
ValueAndTimestampSerializer<V> |
|
WindowKeySchema |
|
WindowStoreBuilder<K,V> |
|
WrappedStateStore<S extends StateStore,K,V> |
A storage engine wrapper for utilities like logging, caching, and metering.
|
WrappingStoreProvider |
|