Github user meiercaleb commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/251#discussion_r153534997
--- Diff:
extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/batch/JoinBatchBindingSetUpdater.java
---
@@ -101,14 +99,14 @@ public void processBatch(TransactionBase tx, Bytes
row, BatchInformation batch)
}
// Insert the new join binding sets to the Fluo table.
- final JoinMetadata joinMetadata = dao.readJoinMetadata(tx, nodeId);
+ final JoinMetadata joinMetadata = CACHE.readJoinMetadata(tx,
nodeId);
final VariableOrder joinVarOrder = joinMetadata.getVariableOrder();
while (newJoinResults.hasNext()) {
final VisibilityBindingSet newJoinResult =
newJoinResults.next();
//create BindingSet value
Bytes bsBytes = BS_SERDE.serialize(newJoinResult);
//make rowId
--- End diff --
Done.
---
