kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改方法名称

This commit is contained in:
zhangxin10 2015-11-18 15:01:26 +08:00
parent 48b143dd9c
commit 7fcaeb34fb
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToHBaseChain.java
View File

@ -24,7 +24,7 @@ public class SaveToHBaseChain implements IStorageChain {
@Override
public void doChain(List<BuriedPointEntry> entry, Chain chain) {
insertBatch(entry);
bulkInsertBuriedPointData(entry);
chain.doChain(entry);
}
@ -93,7 +93,7 @@ public class SaveToHBaseChain implements IStorageChain {
}
private static void insertBatch(List<BuriedPointEntry> entries) {
private static void bulkInsertBuriedPointData(List<BuriedPointEntry> entries) {
List<Put> puts = new ArrayList<Put>();
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<Put> data) {
private static void bulkInsertBuriedPointData(String tableName, List<Put> data) {
Object[] resultArrays = new Object[data.size()];
try {
Table table = connection.getTable(TableName.valueOf(tableName));