Table of Contents

Class KGroupedTable<K, V, TJVMK, TJVMV>

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

KNet extension of KGroupedTable<K, V>

public class KGroupedTable<K, V, TJVMK, TJVMV> : IKNetInnerReference<KGroupedTable<TJVMK, TJVMV>>, IGenericSerDesFactoryApplier, IDisposable

Type Parameters

K
V
TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance
KGroupedTable<K, V, TJVMK, TJVMV>
Implements

Properties

InnerReference

The underlying inner reference used from KNet object instance

public KGroupedTable<TJVMK, TJVMV> InnerReference { get; }

Property Value

KGroupedTable<TJVMK, TJVMV>

Methods

Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR>, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/KGroupedTable.html#aggregate(org.apache.kafka.streams.kstream.Initializer,org.apache.kafka.streams.kstream.Aggregator,org.apache.kafka.streams.kstream.Aggregator)

public KTable<K, VR, TJVMK, TJVMVR> Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg1, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg2objectSuperK : K where Arg2objectSuperV : V

Parameters

arg0 Initializer<VR, TJVMVR>

Initializer<VA, TJVMVA>

arg1 Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>

Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>

arg2 Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>

Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable

Type Parameters

VR
TJVMVR

The JVM type of VR

Arg1objectSuperK

K

Arg1objectSuperV

V

Arg2objectSuperK

K

Arg2objectSuperV

V

Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR>, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Materialized<K, VR, TJVMK, TJVMVR>)

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

public KTable<K, VR, TJVMK, TJVMVR> Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg1, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg2, Materialized<K, VR, TJVMK, TJVMVR> arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg2objectSuperK : K where Arg2objectSuperV : V

Parameters

arg0 Initializer<VR, TJVMVR>

Initializer<VA, TJVMVA>

arg1 Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>

Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>

arg2 Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>

Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>

arg3 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable

Type Parameters

VR
TJVMVR

The JVM type of VR

Arg1objectSuperK

K

Arg1objectSuperV

V

Arg2objectSuperK

K

Arg2objectSuperV

V

Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR>, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Named)

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

public KTable<K, VR, TJVMK, TJVMVR> Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg1, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg2, Named arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg2objectSuperK : K where Arg2objectSuperV : V

Parameters

arg0 Initializer<VR, TJVMVR>

Initializer<VA, TJVMVA>

arg1 Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>

Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>

arg2 Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>

Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>

arg3 Named

Named

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable

Type Parameters

VR
TJVMVR

The JVM type of VR

Arg1objectSuperK

K

Arg1objectSuperV

V

Arg2objectSuperK

K

Arg2objectSuperV

V

Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR>, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Named, Materialized<K, VR, TJVMK, TJVMVR>)

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

public KTable<K, VR, TJVMK, TJVMVR> Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK, Arg2objectSuperV>(Initializer<VR, TJVMVR> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg1, Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg2, Named arg3, Materialized<K, VR, TJVMK, TJVMVR> arg4) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg2objectSuperK : K where Arg2objectSuperV : V

Parameters

arg0 Initializer<VR, TJVMVR>

Initializer<VA, TJVMVA>

arg1 Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>

Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>

arg2 Aggregator<Arg2objectSuperK, Arg2objectSuperV, VR, TJVMK, TJVMV, TJVMVR>

Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>

arg3 Named

Named

arg4 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable

Type Parameters

VR
TJVMVR

The JVM type of VR

Arg1objectSuperK

K

Arg1objectSuperV

V

Arg2objectSuperK

K

Arg2objectSuperV

V

CheckDisposed()

Test if this instance was disposed

protected void CheckDisposed()

Exceptions

ObjectDisposedException

When this instance was disposed

Count()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/KGroupedTable.html#count()

public KTable<K, long, TJVMK, Long> Count()

Returns

KTable<K, long, TJVMK, Long>

KTable

Count(CountingMaterialized<K, TJVMK>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/KGroupedTable.html#count(org.apache.kafka.streams.kstream.Materialized)

public KTable<K, long, TJVMK, Long> Count(CountingMaterialized<K, TJVMK> arg0)

Parameters

arg0 CountingMaterialized<K, TJVMK>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, long, TJVMK, Long>

KTable

Count(Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/KGroupedTable.html#count(org.apache.kafka.streams.kstream.Named)

public KTable<K, long, TJVMK, Long> Count(Named arg0)

Parameters

arg0 Named

Named

Returns

KTable<K, long, TJVMK, Long>

KTable

Count(Named, CountingMaterialized<K, TJVMK>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/KGroupedTable.html#count(org.apache.kafka.streams.kstream.Named,org.apache.kafka.streams.kstream.Materialized)

public KTable<K, long, TJVMK, Long> Count(Named arg0, CountingMaterialized<K, TJVMK> arg1)

Parameters

arg0 Named

Named

arg1 CountingMaterialized<K, TJVMK>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, long, TJVMK, Long>

KTable

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)

Reduce(Reducer<V, TJVMV>, Reducer<V, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/KGroupedTable.html#reduce(org.apache.kafka.streams.kstream.Reducer,org.apache.kafka.streams.kstream.Reducer)

public KTable<K, V, TJVMK, TJVMV> Reduce(Reducer<V, TJVMV> arg0, Reducer<V, TJVMV> arg1)

Parameters

arg0 Reducer<V, TJVMV>

Reducer<V, TJVMV>

arg1 Reducer<V, TJVMV>

Reducer<V, TJVMV>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable

Reduce(Reducer<V, TJVMV>, Reducer<V, TJVMV>, Materialized<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/KGroupedTable.html#reduce(org.apache.kafka.streams.kstream.Reducer,org.apache.kafka.streams.kstream.Reducer,org.apache.kafka.streams.kstream.Materialized)

public KTable<K, V, TJVMK, TJVMV> Reduce(Reducer<V, TJVMV> arg0, Reducer<V, TJVMV> arg1, Materialized<K, V, TJVMK, TJVMV> arg2)

Parameters

arg0 Reducer<V, TJVMV>

Reducer<V, TJVMV>

arg1 Reducer<V, TJVMV>

Reducer<V, TJVMV>

arg2 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable

Reduce(Reducer<V, TJVMV>, Reducer<V, TJVMV>, Named, Materialized<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/KGroupedTable.html#reduce(org.apache.kafka.streams.kstream.Reducer,org.apache.kafka.streams.kstream.Reducer,org.apache.kafka.streams.kstream.Named,org.apache.kafka.streams.kstream.Materialized)

public KTable<K, V, TJVMK, TJVMV> Reduce(Reducer<V, TJVMV> arg0, Reducer<V, TJVMV> arg1, Named arg2, Materialized<K, V, TJVMK, TJVMV> arg3)

Parameters

arg0 Reducer<V, TJVMV>

Reducer<V, TJVMV>

arg1 Reducer<V, TJVMV>

Reducer<V, TJVMV>

arg2 Named

Named

arg3 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable

Operators

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

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

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

Parameters

t KGroupedTable<K, V, TJVMK, TJVMV>

Returns

KGroupedTable<TJVMK, TJVMV>
Edit this page