Class Suppressed<K, TJVMK>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of Suppressed<K>

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

Type Parameters

K

TJVMK

The JVM type of K

Inheritance

object

Suppressed<K, TJVMK>

Implements

IKNetInnerReference<Suppressed<TJVMK>>

IGenericSerDesFactoryApplier

IDisposable

Derived

Suppressed<K>

Properties

InnerReference

The underlying inner reference used from KNet object instance

public Suppressed<TJVMK> InnerReference { get; }

Property Value

Suppressed<TJVMK>

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)

UntilTimeLimit(TimeSpan, BufferConfig)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Suppressed.html#untilTimeLimit(java.time.Duration,org.apache.kafka.streams.kstream.Suppressed.BufferConfig)

public static Suppressed<K, TJVMK> UntilTimeLimit(TimeSpan arg0, Suppressed.BufferConfig arg1)

Parameters

arg0 TimeSpan

TimeSpan

arg1 Suppressed.BufferConfig

Suppressed.BufferConfig

Returns

Suppressed<K, TJVMK>

Suppressed<K, TJVMK>

UntilWindowCloses(StrictBufferConfig)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Suppressed.html#untilWindowCloses(org.apache.kafka.streams.kstream.Suppressed.StrictBufferConfig)

public static Suppressed<Windowed<object>, Windowed<object>> UntilWindowCloses(Suppressed.StrictBufferConfig arg0)

Parameters

arg0 Suppressed.StrictBufferConfig

Suppressed.StrictBufferConfig

Returns

Suppressed<Windowed<object>, Windowed<object>>

Suppressed<K, TJVMK> with Windowed

Operators

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

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

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

Parameters

t Suppressed<K, TJVMK>

Returns

Suppressed<TJVMK>