提交 42b788f1 编写于 作者: wu-sheng's avatar wu-sheng

1.修改少量名称。

上级 17606659
......@@ -49,18 +49,30 @@ public class SpecificTimeCallTreeMergedChainIdContainer {
batchSaveMergedChainId();
}
/**
* 保存被合并的cid信息列表
*
* @throws IOException
* @throws InterruptedException
*/
private void batchSaveMergedChainId() throws IOException, InterruptedException {
List<Put> chainIdPuts = new ArrayList<Put>();
for (Map.Entry<String, List<String>> entry : hasBeenMergedChainIds.entrySet()) {
Put chainIdPut = new Put(entry.getKey().getBytes());
chainIdPut.addColumn(HBaseTableMetaData.TABLE_CALL_CHAIN_TREE_ID_AND_CID_MAPPING.COLUMN_FAMILY_NAME.getBytes()
, "HAS_BEEN_MERGED_CHAIN_ID".getBytes(), new Gson().toJson(entry.getValue()).getBytes());
, HBaseTableMetaData.TABLE_CALL_CHAIN_TREE_ID_AND_CID_MAPPING.COLUMN_NAME.getBytes(), new Gson().toJson(entry.getValue()).getBytes());
chainIdPuts.add(chainIdPut);
}
HBaseUtil.batchSaveHasBeenMergedCID(chainIdPuts);
}
/**
* 保存已经合并的调用链信息,包含调用链明细
*
* @throws IOException
* @throws InterruptedException
*/
private void batchSaveCurrentHasBeenMergedChainInfo() throws IOException, InterruptedException {
List<Put> chainInfoPuts = new ArrayList<Put>();
for (Map.Entry<String, ChainInfo> entry : combineChains.entrySet()) {
......
......@@ -41,6 +41,8 @@ public class HBaseTableMetaData {
public final static class TABLE_CALL_CHAIN_TREE_ID_AND_CID_MAPPING {
public static final String TABLE_NAME = "sw-treeId-cid-mapping";
public static final String COLUMN_FAMILY_NAME = "sw-treeId-cid-mapping";
public static final String COLUMN_FAMILY_NAME = "cids";
public static final String COLUMN_NAME = "been_merged_cid";
}
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册