Class Suppressed<K, TJVMK>

Namespace: MASES.KNet.Streams.Kstream

Assembly: MASES.KNet.dll

KNet extension of Suppressed<K>

public class Suppressed<K, TJVMK> : IGenericSerDesFactoryApplier

Type Parameters

K
TJVMK: The JVM type of K

Inheritance: object

Suppressed<K, TJVMK>

Implements: IGenericSerDesFactoryApplier

Derived: Suppressed<K>

Inherited Members: object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Methods

UntilTimeLimit(TimeSpan, BufferConfig)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.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/3.7.1/org/apache/kafka/streams/kstream/Suppressed.html#untilWindowCloses-org.apache.kafka.streams.kstream.Suppressed.StrictBufferConfig-

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

Parameters

arg0 Suppressed.StrictBufferConfig: Suppressed.StrictBufferConfig

Returns

Suppressed<Windowed, Windowed>: 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>

Edit this page