Class ReadOnlySessionStore<K, AGG, TJVMK, TJVMAGG>

Namespace

MASES.KNet.Streams.State

Assembly

MASES.KNet.dll

KNet implementation of ReadOnlySessionStore<K, AGG>

public class ReadOnlySessionStore<K, AGG, TJVMK, TJVMAGG> : ManagedStore<ReadOnlySessionStore<TJVMK, TJVMAGG>>, IManagedStore<ReadOnlySessionStore<TJVMK, TJVMAGG>>, IGenericSerDesFactoryApplier

Type Parameters

K

The key type

AGG

The value type

TJVMK

The JVM type of K

TJVMAGG

The JVM type of AGG

Inheritance

object

ManagedStore<ReadOnlySessionStore<TJVMK, TJVMAGG>>

ReadOnlySessionStore<K, AGG, TJVMK, TJVMAGG>

Implements

IManagedStore<ReadOnlySessionStore<TJVMK, TJVMAGG>>

IGenericSerDesFactoryApplier

Derived

ReadOnlySessionStore<K, AGG>

Inherited Members

ManagedStore<ReadOnlySessionStore<TJVMK, TJVMAGG>>.Store

ManagedStore<ReadOnlySessionStore<TJVMK, TJVMAGG>>.Factory

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Methods

BackwardFetch(K)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#backwardFetch-java.lang.Object-

public virtual WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG> BackwardFetch(K arg0)

Parameters

arg0 K

K

Returns

WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

BackwardFetch(K, K)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#backwardFetch-java.lang.Object-java.lang.Object-

public virtual WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG> BackwardFetch(K arg0, K arg1)

Parameters

arg0 K

K

arg1 K

K

Returns

WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG>

KeyValueIterator

BackwardFindSessions(K, Instant, Instant)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#backwardFindSessions-java.lang.Object-java.time.Instant-java.time.Instant-

public virtual WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG> BackwardFindSessions(K arg0, Instant arg1, Instant arg2)

Parameters

arg0 K

K

arg1 Instant

Instant

arg2 Instant

Instant

Returns

WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

BackwardFindSessions(K, long, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#backwardFindSessions-java.lang.Object-long-long-

public virtual WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG> BackwardFindSessions(K arg0, long arg1, long arg2)

Parameters

arg0 K

K

arg1 long

long

arg2 long

long

Returns

WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

BackwardFindSessions(K, K, Instant, Instant)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#backwardFindSessions-java.lang.Object-java.lang.Object-java.time.Instant-java.time.Instant-

public virtual WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG> BackwardFindSessions(K arg0, K arg1, Instant arg2, Instant arg3)

Parameters

arg0 K

K

arg1 K

K

arg2 Instant

Instant

arg3 Instant

Instant

Returns

WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

BackwardFindSessions(K, K, long, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#backwardFindSessions-java.lang.Object-java.lang.Object-long-long-

public virtual WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG> BackwardFindSessions(K arg0, K arg1, long arg2, long arg3)

Parameters

arg0 K

K

arg1 K

K

arg2 long

long

arg3 long

long

Returns

WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

Fetch(K)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#fetch-java.lang.Object-

public virtual WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG> Fetch(K arg0)

Parameters

arg0 K

K

Returns

WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG>

KeyValueIterator

Fetch(K, K)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#fetch-java.lang.Object-java.lang.Object-

public virtual WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG> Fetch(K arg0, K arg1)

Parameters

arg0 K

K

arg1 K

K

Returns

WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

FetchSession(K, Instant, Instant)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#fetchSession-java.lang.Object-java.time.Instant-java.time.Instant-

public virtual AGG FetchSession(K arg0, Instant arg1, Instant arg2)

Parameters

arg0 K

K

arg1 Instant

Instant

arg2 Instant

Instant

Returns

AGG

AGG

FetchSession(K, long, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#fetchSession-java.lang.Object-long-long-

public virtual AGG FetchSession(K arg0, long arg1, long arg2)

Parameters

arg0 K

K

arg1 long

long

arg2 long

long

Returns

AGG

AGG

FindSessions(K, Instant, Instant)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#findSessions-java.lang.Object-java.time.Instant-java.time.Instant-

public virtual WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG> FindSessions(K arg0, Instant arg1, Instant arg2)

Parameters

arg0 K

K

arg1 Instant

Instant

arg2 Instant

Instant

Returns

WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

FindSessions(K, long, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#findSessions-java.lang.Object-long-long-

public virtual WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG> FindSessions(K arg0, long arg1, long arg2)

Parameters

arg0 K

K

arg1 long

long

arg2 long

long

Returns

WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

FindSessions(K, K, Instant, Instant)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#findSessions-java.lang.Object-java.lang.Object-java.time.Instant-java.time.Instant-

public virtual WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG> FindSessions(K arg0, K arg1, Instant arg2, Instant arg3)

Parameters

arg0 K

K

arg1 K

K

arg2 Instant

Instant

arg3 Instant

Instant

Returns

WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

FindSessions(K, K, long, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/ReadOnlySessionStore.html#findSessions-java.lang.Object-java.lang.Object-long-long-

public virtual WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG> FindSessions(K arg0, K arg1, long arg2, long arg3)

Parameters

arg0 K

K

arg1 K

K

arg2 long

long

arg3 long

long

Returns

WindowedKeyValueIterator<K, AGG, TJVMK, TJVMAGG>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>