Repository: phoenix Updated Branches: refs/heads/master 16d495a68 -> f071365b9
PHOENIX-3019 Addendum - ImmutableBytesWritable as value of the map Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/f071365b Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/f071365b Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/f071365b Branch: refs/heads/master Commit: f071365b9f6ae8def4a9ae97938969bf52be2522 Parents: 16d495a Author: Samarth <[email protected]> Authored: Fri Jul 22 13:52:55 2016 -0700 Committer: Samarth <[email protected]> Committed: Fri Jul 22 13:52:55 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/phoenix/index/IndexMaintainer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/f071365b/phoenix-core/src/main/java/org/apache/phoenix/index/IndexMaintainer.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/index/IndexMaintainer.java b/phoenix-core/src/main/java/org/apache/phoenix/index/IndexMaintainer.java index 8cdbb98..ee67ca2 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/index/IndexMaintainer.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/index/IndexMaintainer.java @@ -436,7 +436,7 @@ public class IndexMaintainer implements Writable, Iterable<ColumnReference> { PName dataTableFamily = column.getFamilyName(); this.coveredColumns.add(new ColumnReference(dataTableFamily.getBytes(), column.getName().getBytes())); if(isLocalIndex) { - this.dataTableLocalIndexFamilyMap.put(new ImmutableBytesPtr(dataTableFamily.getBytes()), new ImmutableBytesPtr(Bytes.toBytes(IndexUtil.getLocalIndexColumnFamily(dataTableFamily.getString())))); + this.dataTableLocalIndexFamilyMap.put(new ImmutableBytesPtr(dataTableFamily.getBytes()), new ImmutableBytesWritable(Bytes.toBytes(IndexUtil.getLocalIndexColumnFamily(dataTableFamily.getString())))); } } } @@ -1058,7 +1058,7 @@ public class IndexMaintainer implements Writable, Iterable<ColumnReference> { ColumnReference ref = new ColumnReference(cf,cq); coveredColumns.add(ref); if(isLocalIndex) { - dataTableLocalIndexFamilyMap.put(ref.getFamilyWritable(), new ImmutableBytesPtr(Bytes.toBytes(IndexUtil.getLocalIndexColumnFamily(Bytes.toString(cf))))); + dataTableLocalIndexFamilyMap.put(ref.getFamilyWritable(), new ImmutableBytesWritable(Bytes.toBytes(IndexUtil.getLocalIndexColumnFamily(Bytes.toString(cf))))); } } // Hack to serialize whether the index row key is optimizable
