Github user meiercaleb commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/251#discussion_r153533667
--- Diff:
extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/PeriodicQueryUpdater.java
---
@@ -65,18 +64,18 @@ public void updatePeriodicBinResults(TransactionBase
tx, VisibilityBindingSet bs
binnedBs.addBinding(IncrementalUpdateConstants.PERIODIC_BIN_ID,
vf.createLiteral(id));
VisibilityBindingSet visibilityBindingSet = new
VisibilityBindingSet(binnedBs, bs.getVisibility());
Bytes periodicBsBytes =
BS_SERDE.serialize(visibilityBindingSet);
-
- //create row
- final Bytes resultRow =
RowKeyUtil.makeRowKey(metadata.getNodeId(), metadata.getVariableOrder(),
binnedBs);
+
+ //create row
+ final Bytes resultRow = getRowKey(metadata.getNodeId(),
metadata.getVariableOrder(), visibilityBindingSet);
--- End diff --
Done.
---
