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));