Interface IAggregator<K, V, VAgg>

Namespace

Org.Apache.Kafka.Streams.Kstream

Assembly

MASES.KNet.dll

Listener for Kafka Aggregator. Extends IJVMBridgeBase

public interface IAggregator<K, V, VAgg> : IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition

Type Parameters

K

The data associated to the event

V

The data associated to the event

VAgg

Aggregated value

Methods

Apply(K, V, VAgg)

Executes the Aggregator action in the CLR

VAgg Apply(K o1, V o2, VAgg aggregate)

Parameters

o1 K

The Aggregator object

o2 V

The Aggregator object

aggregate VAgg

The current aggregate value

Returns

VAgg

The VAgg apply evaluation