Github user meiercaleb commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/251#discussion_r153533789
--- Diff:
extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/ProjectionResultUpdater.java
---
@@ -65,20 +64,21 @@ public void updateProjectionResults(
log.trace(
"Transaction ID: " + tx.getStartTimestamp() + "\n" +
"Node ID: " + projectionMetadata.getNodeId() + "\n" +
- "Parent Node ID: " + projectionMetadata.getParentNodeId()
+ "\n" +
+ "Parent Node ID: " + projectionMetadata.getParentNodeId()
+ "\n" +
"Child Node ID: " + projectionMetadata.getChildNodeId() +
"\n" +
"Child Binding Set:\n" + childBindingSet + "\n");
// Create the query's Binding Set from the child node's binding
set.
final VariableOrder queryVarOrder =
projectionMetadata.getVariableOrder();
final VariableOrder projectionVarOrder =
projectionMetadata.getProjectedVars();
final BindingSet queryBindingSet =
BindingSetUtil.keepBindings(projectionVarOrder, childBindingSet);
+ VisibilityBindingSet projectedBs = new
VisibilityBindingSet(queryBindingSet, childBindingSet.getVisibility());
// Create the Row Key for the result. If the child node groups
results, then the key must only contain the Group By variables.
- Bytes resultRow =
RowKeyUtil.makeRowKey(projectionMetadata.getNodeId(), queryVarOrder,
queryBindingSet);
+ Bytes resultRow = getRowKey(projectionMetadata.getNodeId(),
queryVarOrder, projectedBs);
--- End diff --
Done.
---
