Interface IMerger<K, V>
Listener for Kafka Merger. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
public interface IMerger<K, V> : IJVMBridgeBase, IJVMBridgeDefinition
Type Parameters
K
The data associated to the event
V
The data associated to the event
- Inherited Members
-
IJVMBridgeBase.MonitorEnter()IJVMBridgeBase.MonitorExit()IJVMBridgeBase.IsInstanceOf(IJavaType)IJVMBridgeBase.IsInstanceOf<T>()IJVMBridgeBase.RuntimeIsInstanceOf<T>()IJVMBridgeBase.CastTo<TNewClass>()IJVMBridgeBase.CastDirect<TNewClass>()IJVMBridgeBase.DynBridgeInstanceIJVMBridgeBase.BridgeInstanceIJVMBridgeDefinition.BridgeClassNameIJVMBridgeDefinition.IsBridgeInterfaceIJVMBridgeDefinition.IsBridgeAbstractIJVMBridgeDefinition.IsBridgeStaticIJVMBridgeDefinition.IsBridgeCloseableIJVMBridgeDefinition.IsBridgeListener
Methods
Apply(K, V, V)
Executes the Merger action in the CLR
V Apply(K aggKey, V aggOne, V aggTwo)
Parameters
aggKey
KThe Merger object
aggOne
VThe Merger object
aggTwo
VThe current aggregate value
Returns
- V
The
V
apply evaluation