Class TimestampedWindowStoreWithHeadersIterator<V, TJVMV>

Namespace

MASES.KNet.Streams.State

Assembly

MASES.KNet.dll

KNet implementation of WindowStoreIterator

public sealed class TimestampedWindowStoreWithHeadersIterator<V, TJVMV> : IGenericSerDesFactoryApplier

Type Parameters

V

The value type

TJVMV

The JVM value type

Inheritance

object

TimestampedWindowStoreWithHeadersIterator<V, TJVMV>

Implements

IGenericSerDesFactoryApplier

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()

Operators

implicit operator TimestampedKeyValueWithHeadersIterator<long, V, Long, TJVMV>(TimestampedWindowStoreWithHeadersIterator<V, TJVMV>)

Converter from TimestampedWindowStoreIterator<V, TJVMV> to KeyValueIterator<K, V, TJVMK, TJVMV>

public static implicit operator TimestampedKeyValueWithHeadersIterator<long, V, Long, TJVMV>(TimestampedWindowStoreWithHeadersIterator<V, TJVMV> t)

Parameters

t TimestampedWindowStoreWithHeadersIterator<V, TJVMV>

Returns

TimestampedKeyValueWithHeadersIterator<long, V, Long, TJVMV>