From 1d68c7e0c91b563919099c0a1f4870e0ca705aa3 Mon Sep 17 00:00:00 2001 From: vernedeng Date: Thu, 21 Nov 2024 16:34:18 +0800 Subject: [PATCH] [INLONG-11520][SDK] Add Common DirtyServerType --- .../inlong/sort/base/dirty/sink/DirtyServerType.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/dirty/sink/DirtyServerType.java b/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/dirty/sink/DirtyServerType.java index 63f993c146..69d029b17e 100644 --- a/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/dirty/sink/DirtyServerType.java +++ b/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/dirty/sink/DirtyServerType.java @@ -21,7 +21,14 @@ public enum DirtyServerType { UNDEFINED("Undefined"), TUBE_MQ("TubeMQ"), - ICEBERG("Iceberg") + ICEBERG("Iceberg"), + HIVE("Hive"), + STAR_ROCKS("StarRocks"), + KAFKA("Kafka"), + PULSAR("Pulsar"), + ELASTICSEARCH("Elasticsearch"), + MYSQL("Mysql"), + SORT_STANDALONE("SortStandalone"), ;