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, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IAggregator<TJVMK, TJVMV, TJVMVA>, IJVMBridgeBase, IJVMBridgeBaseInstance, 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

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<JVMBridgeListener>

JVMBridgeListener

Aggregator<TJVMK, TJVMV, TJVMVA>

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

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IAggregator<TJVMK, TJVMV, TJVMVA>

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

IGenericSerDesFactoryApplier

Derived

Aggregator<K, V, VA>

Inherited Members

Aggregator<TJVMK, TJVMV, TJVMVA>.ListenerShallManageEvent(int)

Aggregator<TJVMK, TJVMV, TJVMVA>.BridgeClassName

Aggregator<TJVMK, TJVMV, TJVMVA>.InitializeHandlers(Type)

Aggregator<TJVMK, TJVMV, TJVMVA>.ListenerShallManageEventHandlers(int)

Aggregator<TJVMK, TJVMV, TJVMVA>.OnApply

Aggregator<TJVMK, TJVMV, TJVMVA>.OnApplyDispose

Aggregator<TJVMK, TJVMV, TJVMVA>.Apply(TJVMK, TJVMV, TJVMVA)

Constructors

Aggregator()

public Aggregator()

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

DisposeResult(TJVMVA)

Disposes the results of the Apply(TJVMK, TJVMV, TJVMVA) or OnApply operations

protected virtual void DisposeResult(TJVMVA result)

Parameters

result TJVMVA

The result to be disposed