Github user isper3at commented on a diff in the pull request:

    https://github.com/apache/incubator-rya/pull/251#discussion_r153008957
  
    --- 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 --
    
    same create vs get doc here


---

Reply via email to