1.初始化默认的数据库存储Chain

This commit is contained in:
wusheng 2015-11-17 14:35:29 +08:00
parent 9994fb383b
commit 9f6d7678b0
1 changed files with 5 additions and 0 deletions

View File

@ -4,12 +4,17 @@ import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import com.ai.cloud.skywalking.reciever.model.BuriedPointEntry;
import com.ai.cloud.skywalking.reciever.storage.chain.SaveToHBaseChain;
public class StorageChainController {
private static Logger logger = LogManager
.getLogger(StorageChainController.class);
private static Chain globalChain = new Chain();
static{
globalChain.addChain(new SaveToHBaseChain());
}
public static void doStorage(String buriedPointDatas) {
String[] buriedPointData = buriedPointDatas.split(";");