Github user meiercaleb commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/251#discussion_r153573688
--- 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) {
+ if(other == null) { return false;}
+ if(this == other) { return true;}
+
+ if (other instanceof BindingSetRow) {
+ BindingSetRow row = (BindingSetRow) other;
+ return new EqualsBuilder().append(this.nodeId,
row.nodeId).append(this.bindingSetString, row.bindingSetString)
--- End diff --
Okay, but only because you were nice enough to code it up for me :)
---
