From 9f6d7678b0108870f5c6cc183ba17debceb9a0d1 Mon Sep 17 00:00:00 2001 From: wusheng Date: Tue, 17 Nov 2015 14:35:29 +0800 Subject: [PATCH] =?UTF-8?q?1.=E5=88=9D=E5=A7=8B=E5=8C=96=E9=BB=98=E8=AE=A4?= =?UTF-8?q?=E7=9A=84=E6=95=B0=E6=8D=AE=E5=BA=93=E5=AD=98=E5=82=A8Chain?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../skywalking/reciever/storage/StorageChainController.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/StorageChainController.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/StorageChainController.java index 8d850d144..d559eafd1 100644 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/StorageChainController.java +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/StorageChainController.java @@ -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(";");