From 5c76e823cbdca744ecbd946e3efc48d76f3fb96b Mon Sep 17 00:00:00 2001 From: gupeng Date: Thu, 28 Dec 2023 14:19:00 +0800 Subject: [PATCH] debug:Delete the useless parseSinkStreamLoadProperties method Signed-off-by: gupeng --- .../flink/table/sink/StarRocksSinkOptions.java | 17 ++--------------- 1 file changed, 2 insertions(+), 15 deletions(-) diff --git a/src/main/java/com/starrocks/connector/flink/table/sink/StarRocksSinkOptions.java b/src/main/java/com/starrocks/connector/flink/table/sink/StarRocksSinkOptions.java index 75401487..f25d8fe5 100644 --- a/src/main/java/com/starrocks/connector/flink/table/sink/StarRocksSinkOptions.java +++ b/src/main/java/com/starrocks/connector/flink/table/sink/StarRocksSinkOptions.java @@ -166,7 +166,6 @@ public enum StreamLoadFormat { private final ReadableConfig tableOptions; private final Map streamLoadProps = new HashMap<>(); - private final Map tableOptionsMap; private StarRocksSinkSemantic sinkSemantic; private boolean supportUpsertDelete; private String[] tableSchemaFieldNames; @@ -175,10 +174,8 @@ public enum StreamLoadFormat { private final List tablePropertiesList = new ArrayList<>(); - public StarRocksSinkOptions(ReadableConfig options, Map optionsMap) { + public StarRocksSinkOptions(ReadableConfig options) { this.tableOptions = options; - this.tableOptionsMap = optionsMap; - parseSinkStreamLoadProperties(); this.validate(); } @@ -459,16 +456,6 @@ private void validateRequired() { "Either all or none of the following options should be provided:\n" + String.join("\n", propertyNames)); } - private void parseSinkStreamLoadProperties() { - tableOptionsMap.keySet().stream() - .filter(key -> key.startsWith(SINK_PROPERTIES_PREFIX)) - .forEach(key -> { - final String value = tableOptionsMap.get(key); - final String subKey = key.substring((SINK_PROPERTIES_PREFIX).length()).toLowerCase(); - streamLoadProps.put(subKey, value); - }); - } - /** * Builder for {@link StarRocksSinkOptions}. */ @@ -484,7 +471,7 @@ public Builder withProperty(String key, String value) { } public StarRocksSinkOptions build() { - return new StarRocksSinkOptions(conf, conf.toMap()); + return new StarRocksSinkOptions(conf); } }