Github user meiercaleb commented on a diff in the pull request: https://github.com/apache/incubator-rya/pull/251#discussion_r153571640 --- Diff: extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/BindingSetRow.java --- @@ -77,4 +78,31 @@ public static BindingSetRow make(final Bytes row) { final String bindingSetString = rowArray.length == 2 ? rowArray[1] : ""; return new BindingSetRow(nodeId, bindingSetString); } + + public static BindingSetRow makeFromShardedRow(Bytes prefixBytes, Bytes row) { + return make(BindingHashShardingFunction.removeHash(prefixBytes, row)); + } + + @Override + public String toString() { + StringBuilder builder = new StringBuilder(); + builder + .append("NodeId: " + nodeId).append("\n") + .append("BindingSet String: " + bindingSetString); + return builder.toString(); + } + + @Override + public boolean equals(Object other) { --- End diff -- Done.
---