Interface IAggregator<K, V, VAgg>
Listener for Kafka Aggregator. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
public interface IAggregator<K, V, VAgg> : IJVMBridgeBase, IJVMBridgeDefinition
Type Parameters
K
The data associated to the event
V
The data associated to the event
VAgg
Aggregated value
- 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, VAgg)
Executes the Aggregator action in the CLR
VAgg Apply(K o1, V o2, VAgg aggregate)
Parameters
o1
KThe Aggregator object
o2
VThe Aggregator object
aggregate
VAggThe current aggregate value
Returns
- VAgg
The
VAgg
apply evaluation