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 4887010e2c570abb216c82aa3e29599d51a4b128..c0bd423fdff5318c01aaa82180f5123315eee626 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 8bd832bbf3e4d99692b7c11f928172b01f932195..0000000000000000000000000000000000000000 --- 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 - - } - -}