Class AggregationWithHeadersIterator<K, AGG, TJVMK, TJVMAGG>

Namespace

MASES.KNet.Streams.State

Assembly

MASES.KNet.dll

KNet implementation of AggregationWithHeaders<AGG>

public sealed class AggregationWithHeadersIterator<K, AGG, TJVMK, TJVMAGG> : CommonIterator<AggregationWithHeaders<AGG, TJVMAGG>>, IGenericSerDesFactoryApplier, IEnumerable<AggregationWithHeaders<AGG, TJVMAGG>>, IEnumerable, IAsyncEnumerable<AggregationWithHeaders<AGG, TJVMAGG>>, IDisposable, IAsyncDisposable, IKNetInnerReference<KeyValueIterator<Windowed<TJVMK>, AggregationWithHeaders<TJVMAGG>>>

Type Parameters

K

The key type

AGG

The key type

TJVMK

The JVM type of K

TJVMAGG

The JVM type of AGG

Inheritance

object

CommonIterator<AggregationWithHeaders<AGG, TJVMAGG>>

AggregationWithHeadersIterator<K, AGG, TJVMK, TJVMAGG>

Implements

IGenericSerDesFactoryApplier

IEnumerable<AggregationWithHeaders<AGG, TJVMAGG>>

IEnumerable

IAsyncEnumerable<AggregationWithHeaders<AGG, TJVMAGG>>

IDisposable

IAsyncDisposable

IKNetInnerReference<KeyValueIterator<Windowed<TJVMK>, AggregationWithHeaders<TJVMAGG>>>

Inherited Members

CommonIterator<AggregationWithHeaders<AGG, TJVMAGG>>.Dispose()

CommonIterator<AggregationWithHeaders<AGG, TJVMAGG>>.DisposeAsync()

CommonIterator<AggregationWithHeaders<AGG, TJVMAGG>>.UsePrefetch

CommonIterator<AggregationWithHeaders<AGG, TJVMAGG>>.GetEnumerator()

CommonIterator<AggregationWithHeaders<AGG, TJVMAGG>>.GetAsyncEnumerator(CancellationToken)

CommonIterator<AggregationWithHeaders<AGG, TJVMAGG>>.ToIEnumerator(bool)

Properties

InnerReference

The underlying inner reference used from KNet object instance

public KeyValueIterator<Windowed<TJVMK>, AggregationWithHeaders<TJVMAGG>> InnerReference { get; }

Property Value

KeyValueIterator<Windowed<TJVMK>, AggregationWithHeaders<TJVMAGG>>

Methods

Close()

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

public void Close()

Dispose(bool)

Implements the pattern described in https://learn.microsoft.com/en-en/dotnet/standard/garbage-collection/implementing-dispose

protected override void Dispose(bool disposing)

Parameters

disposing bool

The disposing parameter is a bool that indicates whether the method call comes from a Dispose() method (its value is true) or from a finalizer (its value is false)

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 AggregationWithHeaders<AGG, TJVMAGG> Next()

Returns

AggregationWithHeaders<AGG, TJVMAGG>

PeekNextKey()

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.3.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()