Class TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of TimeWindowedCogroupedKStream<K, V>

public class TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV> : IGenericSerDesFactoryApplier

Type Parameters

K

V

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV>

Implements

IGenericSerDesFactoryApplier

Inherited Members

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Methods

Aggregate(Initializer<V, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.html#aggregate(org.apache.kafka.streams.kstream.Initializer)

public KTable<K, V, Windowed<TJVMK>, TJVMV> Aggregate(Initializer<V, TJVMV> arg0)

Parameters

arg0 Initializer<V, TJVMV>

Initializer<VA, TJVMVA>

Returns

KTable<K, V, Windowed<TJVMK>, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Aggregate(Initializer<V, TJVMV>, Materialized<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.html#aggregate(org.apache.kafka.streams.kstream.Initializer,org.apache.kafka.streams.kstream.Materialized)

public KTable<K, V, Windowed<TJVMK>, TJVMV> Aggregate(Initializer<V, TJVMV> arg0, Materialized<K, V, TJVMK, TJVMV> arg1)

Parameters

arg0 Initializer<V, TJVMV>

Initializer<VA, TJVMVA>

arg1 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, Windowed<TJVMK>, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Aggregate(Initializer<V, TJVMV>, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.html#aggregate(org.apache.kafka.streams.kstream.Initializer,org.apache.kafka.streams.kstream.Named)

public KTable<K, V, Windowed<TJVMK>, TJVMV> Aggregate(Initializer<V, TJVMV> arg0, Named arg1)

Parameters

arg0 Initializer<V, TJVMV>

Initializer<VA, TJVMVA>

arg1 Named

Named

Returns

KTable<K, V, Windowed<TJVMK>, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Aggregate(Initializer<V, TJVMV>, Named, Materialized<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.html#aggregate(org.apache.kafka.streams.kstream.Initializer,org.apache.kafka.streams.kstream.Named,org.apache.kafka.streams.kstream.Materialized)

public KTable<K, V, Windowed<TJVMK>, TJVMV> Aggregate(Initializer<V, TJVMV> arg0, Named arg1, Materialized<K, V, TJVMK, TJVMV> arg2)

Parameters

arg0 Initializer<V, TJVMV>

Initializer<VA, TJVMVA>

arg1 Named

Named

arg2 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, Windowed<TJVMK>, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Operators

implicit operator TimeWindowedCogroupedKStream<TJVMK, TJVMV>(TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV>)

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

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

Parameters

t TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV>

Returns

TimeWindowedCogroupedKStream<TJVMK, TJVMV>