Class CogroupedKStream<K, VOut, TJVMK, TJVMVOut>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of CogroupedKStream<K, VAgg>

public class CogroupedKStream<K, VOut, TJVMK, TJVMVOut> : IGenericSerDesFactoryApplier

Type Parameters

K

VOut

TJVMK

The JVM type of K

TJVMVOut

The JVM type of VOut

Inheritance

object

CogroupedKStream<K, VOut, TJVMK, TJVMVOut>

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<VOut, TJVMVOut>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/CogroupedKStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-

public KTable<K, VOut, TJVMK, TJVMVOut> Aggregate(Initializer<VOut, TJVMVOut> arg0)

Parameters

arg0 Initializer<VOut, TJVMVOut>

Initializer<VA, TJVMVA>

Returns

KTable<K, VOut, TJVMK, TJVMVOut>

KTable<K, V, TJVMK, TJVMV>

Aggregate(Initializer<VOut, TJVMVOut>, Materialized<K, VOut, TJVMK, TJVMVOut>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/CogroupedKStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VOut, TJVMK, TJVMVOut> Aggregate(Initializer<VOut, TJVMVOut> arg0, Materialized<K, VOut, TJVMK, TJVMVOut> arg1)

Parameters

arg0 Initializer<VOut, TJVMVOut>

Initializer<VA>

arg1 Materialized<K, VOut, TJVMK, TJVMVOut>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VOut, TJVMK, TJVMVOut>

KTable<K, V, TJVMK, TJVMV>

Aggregate(Initializer<VOut, TJVMVOut>, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/CogroupedKStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Named-

public KTable<K, VOut, TJVMK, TJVMVOut> Aggregate(Initializer<VOut, TJVMVOut> arg0, Named arg1)

Parameters

arg0 Initializer<VOut, TJVMVOut>

Initializer<VA, TJVMVA>

arg1 Named

Named

Returns

KTable<K, VOut, TJVMK, TJVMVOut>

KTable<K, V, TJVMK, TJVMV>

Aggregate(Initializer<VOut, TJVMVOut>, Named, Materialized<K, VOut, TJVMK, TJVMVOut>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/CogroupedKStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Named-org.apache.kafka.streams.kstream.Materialized-

public KTable<K, VOut, TJVMK, TJVMVOut> Aggregate(Initializer<VOut, TJVMVOut> arg0, Named arg1, Materialized<K, VOut, TJVMK, TJVMVOut> arg2)

Parameters

arg0 Initializer<VOut, TJVMVOut>

Initializer<VA, TJVMVA>

arg1 Named

Named

arg2 Materialized<K, VOut, TJVMK, TJVMVOut>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VOut, TJVMK, TJVMVOut>

KTable<K, V, TJVMK, TJVMV>

Cogroup<VIn, TJVMVIn, Arg1objectSuperK, Arg1objectSuperVIn>(KGroupedStream<K, VIn, TJVMK, TJVMVIn>, Aggregator<Arg1objectSuperK, Arg1objectSuperVIn, VOut, TJVMK, TJVMVIn, TJVMVOut>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/CogroupedKStream.html#cogroup-org.apache.kafka.streams.kstream.KGroupedStream-org.apache.kafka.streams.kstream.Aggregator-

public CogroupedKStream<K, VOut, TJVMK, TJVMVOut> Cogroup<VIn, TJVMVIn, Arg1objectSuperK, Arg1objectSuperVIn>(KGroupedStream<K, VIn, TJVMK, TJVMVIn> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperVIn, VOut, TJVMK, TJVMVIn, TJVMVOut> arg1) where Arg1objectSuperK : K where Arg1objectSuperVIn : VIn

Parameters

arg0 KGroupedStream<K, VIn, TJVMK, TJVMVIn>

KGroupedStream<K, V, TJVMK, TJVMV>

arg1 Aggregator<Arg1objectSuperK, Arg1objectSuperVIn, VOut, TJVMK, TJVMVIn, TJVMVOut>

Aggregator<K, V, VA>

Returns

CogroupedKStream<K, VOut, TJVMK, TJVMVOut>

CogroupedKStream<K, VOut, TJVMK, TJVMVOut>

Type Parameters

VIn

TJVMVIn

The JVM type of VIn

Arg1objectSuperK

K

Arg1objectSuperVIn

VIn

WindowedBy(SessionWindows)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/CogroupedKStream.html#windowedBy-org.apache.kafka.streams.kstream.SessionWindows-

public SessionWindowedCogroupedKStream<K, VOut, TJVMK, TJVMVOut> WindowedBy(SessionWindows arg0)

Parameters

arg0 SessionWindows

SessionWindows

Returns

SessionWindowedCogroupedKStream<K, VOut, TJVMK, TJVMVOut>

SessionWindowedCogroupedKStream<K, V, TJVMK, TJVMV>

WindowedBy(SlidingWindows)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/CogroupedKStream.html#windowedBy-org.apache.kafka.streams.kstream.SlidingWindows-

public TimeWindowedCogroupedKStream<K, VOut, TJVMK, TJVMVOut> WindowedBy(SlidingWindows arg0)

Parameters

arg0 SlidingWindows

SlidingWindows

Returns

TimeWindowedCogroupedKStream<K, VOut, TJVMK, TJVMVOut>

TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV>

WindowedBy<W>(Windows<W>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/CogroupedKStream.html#windowedBy-org.apache.kafka.streams.kstream.Windows-

public TimeWindowedCogroupedKStream<K, VOut, TJVMK, TJVMVOut> WindowedBy<W>(Windows<W> arg0) where W : Window

Parameters

arg0 Windows<W>

Windows

Returns

TimeWindowedCogroupedKStream<K, VOut, TJVMK, TJVMVOut>

TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV>

Type Parameters

W

Window

Operators

implicit operator CogroupedKStream<TJVMK, TJVMVOut>(CogroupedKStream<K, VOut, TJVMK, TJVMVOut>)

Converter from CogroupedKStream<K, VOut, TJVMK, TJVMVOut> to CogroupedKStream<K, VAgg>

public static implicit operator CogroupedKStream<TJVMK, TJVMVOut>(CogroupedKStream<K, VOut, TJVMK, TJVMVOut> t)

Parameters

t CogroupedKStream<K, VOut, TJVMK, TJVMVOut>

Returns

CogroupedKStream<TJVMK, TJVMVOut>