Aggregate all the incomingMsgs first, then make a decision based aggregateMsg
4 files changed
tree: 0572adcca627cc902c2d0e30d66175bd45156dec
  1. .gitignore
  2. algebricks/
  3. genomix/
  4. hivesterix/
  5. hyracks/
  6. pom.xml
  7. pregelix/