Class TimestampedKeyValueStore<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Streams.State

Assembly

MASES.KNet.dll

KNet implementation of ReadOnlySessionStore<K, AGG>

public class TimestampedKeyValueStore<K, V, TJVMK, TJVMV> : ManagedStore<ReadOnlyKeyValueStore<TJVMK, ValueAndTimestamp<TJVMV>>>, IManagedStore<ReadOnlyKeyValueStore<TJVMK, ValueAndTimestamp<TJVMV>>>, IGenericSerDesFactoryApplier

Type Parameters

K

The key type

V

The value type

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

ManagedStore<ReadOnlyKeyValueStore<TJVMK, ValueAndTimestamp<TJVMV>>>

TimestampedKeyValueStore<K, V, TJVMK, TJVMV>

Implements

IManagedStore<ReadOnlyKeyValueStore<TJVMK, ValueAndTimestamp<TJVMV>>>

IGenericSerDesFactoryApplier

Derived

TimestampedKeyValueStore<K, V>

Inherited Members

ManagedStore<ReadOnlyKeyValueStore<TJVMK, ValueAndTimestamp<TJVMV>>>.Store

ManagedStore<ReadOnlyKeyValueStore<TJVMK, ValueAndTimestamp<TJVMV>>>.Factory

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Methods

All()

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.0/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html#all()

public virtual TimestampedKeyValueIterator<K, V, TJVMK, TJVMV> All()

Returns

TimestampedKeyValueIterator<K, V, TJVMK, TJVMV>

KeyValueIterator<K, V, TJVMK, TJVMV>

ApproximateNumEntries()

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.0/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html#approximateNumEntries()

public virtual long ApproximateNumEntries()

Returns

long

long

Get(K)

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.0/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html#get(java.lang.Object)

public virtual ValueAndTimestamp<V, TJVMV> Get(K arg0)

Parameters

arg0 K

K

Returns

ValueAndTimestamp<V, TJVMV>

V

PrefixScan<P, TJVMP>(P, ISerDes<P, TJVMP>)

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.0/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html#prefixScan(java.lang.Object,org.apache.kafka.common.serialization.Serializer)

public TimestampedKeyValueIterator<K, V, TJVMK, TJVMV> PrefixScan<P, TJVMP>(P arg0, ISerDes<P, TJVMP> arg1)

Parameters

arg0 P

arg1 ISerDes<P, TJVMP>

Returns

TimestampedKeyValueIterator<K, V, TJVMK, TJVMV>

TimestampedKeyValueIterator<K, V, TJVMK, TJVMV>

Type Parameters

P

TJVMP

Range(K, K)

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.0/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html#range(java.lang.Object,java.lang.Object)

public virtual TimestampedKeyValueIterator<K, V, TJVMK, TJVMV> Range(K arg0, K arg1)

Parameters

arg0 K

K

arg1 K

V

Returns

TimestampedKeyValueIterator<K, V, TJVMK, TJVMV>

KeyValueIterator<K, V, TJVMK, TJVMV>

ReverseAll()

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.0/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html#reverseAll()

public virtual TimestampedKeyValueIterator<K, V, TJVMK, TJVMV> ReverseAll()

Returns

TimestampedKeyValueIterator<K, V, TJVMK, TJVMV>

KeyValueIterator<K, V, TJVMK, TJVMV>

ReverseRange(K, K)

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.0/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html#reverseRange(java.lang.Object,java.lang.Object)

public virtual TimestampedKeyValueIterator<K, V, TJVMK, TJVMV> ReverseRange(K arg0, K arg1)

Parameters

arg0 K

K

arg1 K

K

Returns

TimestampedKeyValueIterator<K, V, TJVMK, TJVMV>

KeyValueIterator<K, V, TJVMK, TJVMV>