Skip to content

Commit

Permalink
fix name
Browse files Browse the repository at this point in the history
  • Loading branch information
vernedeng committed Oct 7, 2023
1 parent 2e86f57 commit 4ad207e
Show file tree
Hide file tree
Showing 5 changed files with 9 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -411,7 +411,7 @@ private Map<String, IdTopicConfig> 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)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,20 +40,20 @@ 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<String, String> params = new HashMap<>();

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;
}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down

0 comments on commit 4ad207e

Please sign in to comment.