Table of Contents

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

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

KNet implementation of Aggregator<K, V, VAgg>

public class Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA> : Aggregator<TJVMK, TJVMV, TJVMVA>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IAggregator<TJVMK, TJVMV, TJVMVA>, IJVMBridgeBase, IJVMBridgeDefinition, IGenericSerDesFactoryApplier

Type Parameters

K
V
VA

The key type

TJVMK

The JVM type of K

TJVMV

The JVM type of V

TJVMVA

The JVM type of VA

Inheritance
Aggregator<TJVMK, TJVMV, TJVMVA>
Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>
Implements
IAggregator<TJVMK, TJVMV, TJVMVA>
Derived
Inherited Members

Properties

Aggregate

The VA content

public virtual VA Aggregate { get; }

Property Value

VA

Factory

Returns the current IGenericSerDesFactory

protected IGenericSerDesFactory Factory { get; }

Property Value

IGenericSerDesFactory

Key

The K content

public virtual K Key { get; }

Property Value

K

OnApply

Handler for Apply(K, V, VAgg)

public Func<Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>, VA> OnApply { get; set; }

Property Value

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

Remarks

If OnApply has a value it takes precedence over corresponding class method Apply()

Value

The V content

public virtual V Value { get; }

Property Value

V

Methods

Apply()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/Aggregator.html#apply(java.lang.Object,java.lang.Object,java.lang.Object)

public virtual VA Apply()

Returns

VA

VAgg

Apply(TJVMK, TJVMV, TJVMVA)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/Aggregator.html#apply(java.lang.Object,java.lang.Object,java.lang.Object)

public override sealed TJVMVA Apply(TJVMK arg0, TJVMV arg1, TJVMVA arg2)

Parameters

arg0 TJVMK

K

arg1 TJVMV

V

arg2 TJVMVA

VAgg

Returns

TJVMVA

VAgg

Edit this page