Class WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Streams.State

Assembly

MASES.KNet.dll

KNet implementation of KeyValueIterator<K, V> where K is Windowed<K>

public sealed class WindowedKeyValueIterator<K, V, TJVMK, TJVMV> : CommonIterator<WindowedKeyValue<K, V, TJVMK, TJVMV>>, IGenericSerDesFactoryApplier, IEnumerable<WindowedKeyValue<K, V, TJVMK, TJVMV>>, IEnumerable, IAsyncEnumerable<WindowedKeyValue<K, V, TJVMK, TJVMV>>

Type Parameters

K

The key type

V

The value type

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

CommonIterator<WindowedKeyValue<K, V, TJVMK, TJVMV>>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

Implements

IGenericSerDesFactoryApplier

IEnumerable<WindowedKeyValue<K, V, TJVMK, TJVMV>>

IEnumerable

IAsyncEnumerable<WindowedKeyValue<K, V, TJVMK, TJVMV>>

Inherited Members

CommonIterator<WindowedKeyValue<K, V, TJVMK, TJVMV>>.UsePrefetch

CommonIterator<WindowedKeyValue<K, V, TJVMK, TJVMV>>.GetEnumerator()

CommonIterator<WindowedKeyValue<K, V, TJVMK, TJVMV>>.GetAsyncEnumerator(CancellationToken)

CommonIterator<WindowedKeyValue<K, V, TJVMK, TJVMV>>.ToIEnumerator(bool)

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

Methods

Close()

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/KeyValueIterator.html#close--

public void Close()

GetEnumerator(bool, bool, CancellationToken)

Internally gets the IEnumerable<T> or IAsyncEnumerable<T>

protected override sealed object GetEnumerator(bool isAsync, bool usePrefetch, CancellationToken cancellationToken = default)

Parameters

isAsync bool

true if requesting an IAsyncEnumerator<T>

usePrefetch bool

true if requesting prefetch behavior

cancellationToken CancellationToken

The CancellationToken to be used in IAsyncEnumerator<T>

Returns

object

An IEnumerable<T> or IAsyncEnumerable<T>

HasNext()

KNet implementation of https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/Iterator.html#hasNext()

public bool HasNext()

Returns

bool

Next()

KNet implementation of https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/Iterator.html#next()

public WindowedKeyValue<K, V, TJVMK, TJVMV> Next()

Returns

WindowedKeyValue<K, V, TJVMK, TJVMV>

PeekNextKey()

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/state/KeyValueIterator.html#peekNextKey--

public Windowed<K, TJVMK> PeekNextKey()

Returns

Windowed<K, TJVMK>

K

Remove()

https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/Iterator.html#remove()

public void Remove()