public static class TwoDataFlowsExample.Aggregator extends java.lang.Object implements IFunction
Constructor and Description |
---|
Aggregator() |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
onMessage(java.lang.Object object1,
java.lang.Object object2)
The actual message callback
|