Class Windowed<K, TJVMK>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet implementation of Windowed<K>

public class Windowed<K, TJVMK> : IKNetInnerReference<Windowed<TJVMK>>, IGenericSerDesFactoryApplier, IDisposable

Type Parameters

K

The key type

TJVMK

The JVM type of K

Inheritance

object

Windowed<K, TJVMK>

Implements

IKNetInnerReference<Windowed<TJVMK>>

IGenericSerDesFactoryApplier

IDisposable

Properties

InnerReference

The underlying inner reference used from KNet object instance

public Windowed<TJVMK> InnerReference { get; }

Property Value

Windowed<TJVMK>

Key

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

public K Key { get; }

Property Value

K

K

Window

KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Windowed.html#window()

public Window Window { get; }

Property Value

Window

Window

Methods

CheckDisposed()

Test if this instance was disposed

protected void CheckDisposed()

Exceptions

ObjectDisposedException

When this instance was disposed

Dispose()

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

public void Dispose()

Dispose(bool)

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

protected virtual 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)

Operators

implicit operator Windowed<TJVMK>(Windowed<K, TJVMK>)

Converter from Windowed<K, TJVMK> to Windowed<K>

public static implicit operator Windowed<TJVMK>(Windowed<K, TJVMK> t)

Parameters

t Windowed<K, TJVMK>

Returns

Windowed<TJVMK>