From ef4b76246705c207964ec68eb9d4707a26542819 Mon Sep 17 00:00:00 2001 From: wusheng Date: Mon, 11 Apr 2016 16:33:24 +0800 Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E9=99=A4tracelog=E6=8F=92=E5=85=A5hba?= =?UTF-8?q?se=E7=9A=84=E5=85=A5=E5=BA=93=E6=A8=A1=E5=BC=8F=E3=80=82?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E9=87=8F=E4=BC=9A=E5=BF=AB=E9=80=9F=E5=A2=9E?= =?UTF-8?q?=E9=95=BF=E5=88=B0=E7=99=BE=E4=B8=87=E4=BB=A5=E4=B8=8A=EF=BC=8C?= =?UTF-8?q?=E4=B8=8D=E9=80=82=E5=90=88mysql=E6=95=B0=E6=8D=AE=E5=BA=93?= =?UTF-8?q?=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../storage/StorageChainController.java | 18 ++++++++---------- .../storage/chain/SaveToMySQLChain.java | 17 ----------------- 2 files changed, 8 insertions(+), 27 deletions(-) delete mode 100644 skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToMySQLChain.java 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 4887010e2..c0bd423fd 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 @@ -1,19 +1,19 @@ package com.ai.cloud.skywalking.reciever.storage; +import static com.ai.cloud.skywalking.reciever.conf.Config.StorageChain.STORAGE_TYPE; + +import java.util.ArrayList; +import java.util.List; + +import org.apache.logging.log4j.LogManager; +import org.apache.logging.log4j.Logger; + import com.ai.cloud.skywalking.protocol.Span; import com.ai.cloud.skywalking.reciever.conf.Constants; import com.ai.cloud.skywalking.reciever.selfexamination.ServerHealthCollector; import com.ai.cloud.skywalking.reciever.selfexamination.ServerHeathReading; import com.ai.cloud.skywalking.reciever.storage.chain.AlarmChain; import com.ai.cloud.skywalking.reciever.storage.chain.SaveToHBaseChain; -import com.ai.cloud.skywalking.reciever.storage.chain.SaveToMySQLChain; -import org.apache.logging.log4j.LogManager; -import org.apache.logging.log4j.Logger; - -import java.util.ArrayList; -import java.util.List; - -import static com.ai.cloud.skywalking.reciever.conf.Config.StorageChain.STORAGE_TYPE; public class StorageChainController { private static Logger logger = LogManager @@ -25,8 +25,6 @@ public class StorageChainController { if (STORAGE_TYPE.equalsIgnoreCase("hbase")) { chainArray.add(new AlarmChain()); chainArray.add(new SaveToHBaseChain()); - } else if (STORAGE_TYPE.equalsIgnoreCase("mysql")) { - chainArray.add(new SaveToMySQLChain()); } else { throw new RuntimeException("illegal storage type."); } diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToMySQLChain.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToMySQLChain.java deleted file mode 100644 index 8bd832bbf..000000000 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/chain/SaveToMySQLChain.java +++ /dev/null @@ -1,17 +0,0 @@ -package com.ai.cloud.skywalking.reciever.storage.chain; - -import com.ai.cloud.skywalking.protocol.Span; -import com.ai.cloud.skywalking.reciever.storage.Chain; -import com.ai.cloud.skywalking.reciever.storage.IStorageChain; - -import java.util.List; - -public class SaveToMySQLChain implements IStorageChain { - - @Override - public void doChain(List entry, Chain chain) { - // TODO Auto-generated method stub - - } - -}