Table of Contents

Class CogroupedKStream<K, VOut, TJVMK, TJVMVOut>

Namespace
MASES.KNet.Streams.Kstream
Assembly
MASES.KNet.dll

KNet extension of CogroupedKStream<K, VOut>

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

Type Parameters

K
VOut
TJVMK

The JVM type of K

TJVMVOut

The JVM type of VOut

Inheritance
CogroupedKStream<K, VOut, TJVMK, TJVMVOut>
Implements

Properties

InnerReference

The underlying inner reference used from KNet object instance

public CogroupedKStream<TJVMK, TJVMVOut> InnerReference { get; }

Property Value

CogroupedKStream<TJVMK, TJVMVOut>

Methods

Aggregate(Initializer<VOut, TJVMVOut>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.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/4.2.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/4.2.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/4.2.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>

CheckDisposed()

Test if this instance was disposed

protected void CheckDisposed()

Exceptions

ObjectDisposedException

When this instance was disposed

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/4.2.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

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)

WindowedBy(SessionWindows)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.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/4.2.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/4.2.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, VOut>

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

Parameters

t CogroupedKStream<K, VOut, TJVMK, TJVMVOut>

Returns

CogroupedKStream<TJVMK, TJVMVOut>
Edit this page