From c3787215efecd3653ebf12ee5012dbab76d0577d Mon Sep 17 00:00:00 2001 From: Jaehong Kim Date: Wed, 23 Sep 2015 18:53:29 +0900 Subject: [PATCH] add comment. --- .../pinpoint/collector/dao/hbase/statistics/RowKeyMerge.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/collector/src/main/java/com/navercorp/pinpoint/collector/dao/hbase/statistics/RowKeyMerge.java b/collector/src/main/java/com/navercorp/pinpoint/collector/dao/hbase/statistics/RowKeyMerge.java index e70d9c46c..2955699d4 100644 --- a/collector/src/main/java/com/navercorp/pinpoint/collector/dao/hbase/statistics/RowKeyMerge.java +++ b/collector/src/main/java/com/navercorp/pinpoint/collector/dao/hbase/statistics/RowKeyMerge.java @@ -58,8 +58,10 @@ public class RowKeyMerge { RowKey rowKey = rowKeyEntry.getKey(); byte[] key = null; if(rowKeyDistributorByHashPrefix == null) { + // backward compatibility. key = rowKey.getRowKey(); } else { + // distributed key. key = rowKeyDistributorByHashPrefix.getDistributedKey(rowKey.getRowKey()); } final Increment increment = new Increment(key);