Class TimestampedWindowedKeyValue<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Streams

Assembly

MASES.KNet.dll

KNet implementation of KeyValue<K, V>

public sealed class TimestampedWindowedKeyValue<K, V, TJVMK, TJVMV> : IKNetInnerReference<KeyValue<Windowed<TJVMK>, ValueAndTimestamp<TJVMV>>>, IGenericSerDesFactoryApplier, IDisposable

Type Parameters

K

The key type

V

The value type

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

TimestampedWindowedKeyValue<K, V, TJVMK, TJVMV>

Implements

IKNetInnerReference<KeyValue<Windowed<TJVMK>, ValueAndTimestamp<TJVMV>>>

IGenericSerDesFactoryApplier

IDisposable

Properties

InnerReference

The underlying inner reference used from KNet object instance

public KeyValue<Windowed<TJVMK>, ValueAndTimestamp<TJVMV>> InnerReference { get; }

Property Value

KeyValue<Windowed<TJVMK>, ValueAndTimestamp<TJVMV>>

Key

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/KeyValue.html#key

public Windowed<K, TJVMK> Key { get; }

Property Value

Windowed<K, TJVMK>

Value

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/KeyValue.html#value

public ValueAndTimestamp<V, TJVMV> Value { get; }

Property Value

ValueAndTimestamp<V, TJVMV>

Methods

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()