Github user meiercaleb commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/240#discussion_r145807342
--- Diff:
extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/batch/JoinBatchBindingSetUpdater.java
---
@@ -74,53 +76,60 @@ public void processBatch(TransactionBase tx, Bytes row,
BatchInformation batch)
Preconditions.checkArgument(batch instanceof JoinBatchInformation);
JoinBatchInformation joinBatch = (JoinBatchInformation) batch;
Task task = joinBatch.getTask();
+ VisibilityBindingSet bs = joinBatch.getBs();
- // Figure out which join algorithm we are going to use.
- final IterativeJoin joinAlgorithm;
- switch (joinBatch.getJoinType()) {
- case NATURAL_JOIN:
- joinAlgorithm = new NaturalJoin();
- break;
- case LEFT_OUTER_JOIN:
- joinAlgorithm = new LeftOuterJoin();
- break;
- default:
- throw new RuntimeException("Unsupported JoinType: " +
joinBatch.getJoinType());
+ // create aggregation state manager is aggregation state metadata
exists
--- End diff --
Done
---
