Class GlobalKTable<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of GlobalKTable<K, V>

public class GlobalKTable<K, V, TJVMK, TJVMV> : IKNetInnerReference<GlobalKTable<TJVMK, TJVMV>>, IGenericSerDesFactoryApplier, IDisposable

Type Parameters

K

V

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

GlobalKTable<K, V, TJVMK, TJVMV>

Implements

IKNetInnerReference<GlobalKTable<TJVMK, TJVMV>>

IGenericSerDesFactoryApplier

IDisposable

Properties

InnerReference

The underlying inner reference used from KNet object instance

public GlobalKTable<TJVMK, TJVMV> InnerReference { get; }

Property Value

GlobalKTable<TJVMK, TJVMV>

QueryableStoreName

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/GlobalKTable.html#queryableStoreName()

public string QueryableStoreName { get; }

Property Value

string

String

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 GlobalKTable<TJVMK, TJVMV>(GlobalKTable<K, V, TJVMK, TJVMV>)

Converter from GlobalKTable<K, V, TJVMK, TJVMV> to GlobalKTable<K, V>

public static implicit operator GlobalKTable<TJVMK, TJVMV>(GlobalKTable<K, V, TJVMK, TJVMV> t)

Parameters

t GlobalKTable<K, V, TJVMK, TJVMV>

Returns

GlobalKTable<TJVMK, TJVMV>