From 4ad207e28cf74333e642182fa88f533f3b052dd1 Mon Sep 17 00:00:00 2001 From: vernedeng Date: Sat, 7 Oct 2023 10:57:03 +0800 Subject: [PATCH] fix name --- .../dataproxy/config/holder/MetaConfigHolder.java | 2 +- .../inlong/dataproxy/config/pojo/IdTopicConfig.java | 10 +++++----- .../manager/pojo/stream/InlongStreamExtParam.java | 2 +- .../inlong/manager/pojo/stream/InlongStreamInfo.java | 2 +- .../manager/pojo/stream/InlongStreamRequest.java | 2 +- 5 files changed, 9 insertions(+), 9 deletions(-) diff --git a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/holder/MetaConfigHolder.java b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/holder/MetaConfigHolder.java index 37273326db1..5799222d484 100644 --- a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/holder/MetaConfigHolder.java +++ b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/holder/MetaConfigHolder.java @@ -411,7 +411,7 @@ private Map buildCacheTopicConfig( idObject.getParams().getOrDefault("dataType", DataType.TEXT.value()))); tmpConfig.setFieldDelimiter(idObject.getParams().getOrDefault("fieldDelimiter", "|")); tmpConfig.setFileDelimiter(idObject.getParams().getOrDefault("fileDelimiter", "\n")); - tmpConfig.setSupportExtendedFields(Boolean.valueOf( + tmpConfig.setUseExtendedFields(Boolean.valueOf( idObject.getParams().getOrDefault("supportExtendedFields", "false"))); tmpTopicConfigMap.put(tmpConfig.getUid(), tmpConfig); if (mqType.equals(CacheType.TUBE) diff --git a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/pojo/IdTopicConfig.java b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/pojo/IdTopicConfig.java index a03d24666d4..31646fd3b53 100644 --- a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/pojo/IdTopicConfig.java +++ b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/pojo/IdTopicConfig.java @@ -40,7 +40,7 @@ public class IdTopicConfig { private DataType dataType = DataType.TEXT; private String fieldDelimiter = "|"; private String fileDelimiter = "\n"; - private Boolean supportExtendedFields = false; + private Boolean useExtendedFields = false; private Map params = new HashMap<>(); @@ -48,12 +48,12 @@ public IdTopicConfig() { } - public Boolean getSupportExtendedFields() { - return supportExtendedFields; + public Boolean getUseExtendedFields() { + return useExtendedFields; } - public void setSupportExtendedFields(Boolean supportExtendedFields) { - this.supportExtendedFields = supportExtendedFields; + public void setUseExtendedFields(Boolean useExtendedFields) { + this.useExtendedFields = useExtendedFields; } /** diff --git a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamExtParam.java b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamExtParam.java index 5af9bce32ca..fa9b112224b 100644 --- a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamExtParam.java +++ b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamExtParam.java @@ -46,7 +46,7 @@ public class InlongStreamExtParam implements Serializable { private boolean ignoreParseError; @ApiModelProperty(value = "If support extended fields") - private Boolean supportExtendedFields = false; + private Boolean useExtendedFields = false; /** * Pack extended attributes into ExtParams diff --git a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamInfo.java b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamInfo.java index 37c3ef9641a..8a3ef260d6e 100644 --- a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamInfo.java +++ b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamInfo.java @@ -134,7 +134,7 @@ public class InlongStreamInfo extends BaseInlongStream { private String wrapType; @ApiModelProperty(value = "If support extended fields") - private Boolean supportExtendedFields = false; + private Boolean useExtendedFields = false; @ApiModelProperty(value = "Whether to ignore the parse errors of field value") private Boolean ignoreParseError = true; diff --git a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamRequest.java b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamRequest.java index dc60bbaaed3..14eddcc03a7 100644 --- a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamRequest.java +++ b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamRequest.java @@ -122,7 +122,7 @@ public class InlongStreamRequest extends BaseInlongStream { private boolean ignoreParseError = true; @ApiModelProperty(value = "If support extended fields") - private Boolean supportExtendedFields = false; + private Boolean useExtendedFields = false; @ApiModelProperty(value = "The message body wrap type, including: RAW, INLONG_MSG_V0, INLONG_MSG_V1, PB, etc") private String wrapType;