From 7fcaeb34fb18f8d1eda1630b38895dcc22168147 Mon Sep 17 00:00:00 2001 From: zhangxin10 Date: Wed, 18 Nov 2015 15:01:26 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=96=B9=E6=B3=95=E5=90=8D?= =?UTF-8?q?=E7=A7=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../reciever/storage/chain/SaveToHBaseChain.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java index acd7b8f88..6d642c84c 100644 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java @@ -24,7 +24,7 @@ public class SaveToHBaseChain implements IStorageChain { @Override public void doChain(List entry, Chain chain) { - insertBatch(entry); + bulkInsertBuriedPointData(entry); chain.doChain(entry); } @@ -93,7 +93,7 @@ public class SaveToHBaseChain implements IStorageChain { } - private static void insertBatch(List entries) { + private static void bulkInsertBuriedPointData(List entries) { List puts = new ArrayList(); Put put; for (BuriedPointEntry buriedPointEntry : entries) { @@ -108,10 +108,10 @@ public class SaveToHBaseChain implements IStorageChain { puts.add(put); } - insertBatch(Config.HBaseConfig.TABLE_NAME, puts); + bulkInsertBuriedPointData(Config.HBaseConfig.TABLE_NAME, puts); } - private static void insertBatch(String tableName, List data) { + private static void bulkInsertBuriedPointData(String tableName, List data) { Object[] resultArrays = new Object[data.size()]; try { Table table = connection.getTable(TableName.valueOf(tableName));