Interface IMerger<K, V>
Listener for Kafka Merger. Extends IJVMBridgeBase
public interface IMerger<K, V> : IJVMBridgeBase, IJVMBridgeDefinitionType Parameters
KThe data associated to the event
VThe data associated to the event
- Inherited Members
Methods
Apply(K, V, V)
Executes the Merger action in the CLR
V Apply(K aggKey, V aggOne, V aggTwo)Parameters
aggKeyKThe Merger object
aggOneVThe Merger object
aggTwoVThe current aggregate value
Returns
- V
The
Vapply evaluation