Skip to content

Commit

Permalink
Optimized code
Browse files Browse the repository at this point in the history
  • Loading branch information
ChengJie1053 committed Dec 26, 2023
1 parent 41bbe0a commit 97d1f69
Showing 1 changed file with 19 additions and 17 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,60 +22,62 @@
public class DorisConfiguration {

public static final CommonVars<Integer> ENGINE_CONCURRENT_LIMIT =
CommonVars.apply("linkis.engineconn.doris.concurrent.limit", 100);
CommonVars.apply("linkis.engineconn.concurrent.limit", 100);

public static final CommonVars<Integer> ENGINE_DEFAULT_LIMIT =
CommonVars.apply("linkis.doris.default.limit", 5000);
CommonVars.apply("linkis.ec.doris.default.limit", 5000);

public static final CommonVars<String> DORIS_COLUMN_SEPARATOR =
CommonVars.apply("linkis.doris.column.separator", ",");
CommonVars.apply("linkis.ec.doris.column.separator", ",");

public static final CommonVars<String> DORIS_LINE_DELIMITER =
CommonVars.apply("linkis.doris.line.delimiter", "\\n");
CommonVars.apply("linkis.ec.doris.line.delimiter", "\\n");

public static final CommonVars<String> DORIS_STREAM_LOAD_FILE_PATH =
CommonVars.apply(
"linkis.doris.stream.load.file.path",
"linkis.ec.doris.stream.load.file.path",
"",
"A file path, for example: /test/test.csv, currently supports csv、json、parquet、orc format");

public static final CommonVars<String> DORIS_COLUMNS =
CommonVars.apply("linkis.doris.columns", "");
CommonVars.apply("linkis.ec.doris.columns", "");

public static final CommonVars<String> DORIS_LABEL = CommonVars.apply("linkis.doris.label", "");
public static final CommonVars<String> DORIS_LABEL =
CommonVars.apply("linkis.ec.doris.label", "");

public static final CommonVars<String> DORIS_CONF =
CommonVars.apply(
"linkis.doris.conf",
"linkis.ec.doris.conf",
"",
"The doris parameter, separated by commas, for example: timeout:600,label:123");

public static final CommonVars<String> DORIS_HOST =
CommonVars.apply("linkis.doris.host", "127.0.0.1");
CommonVars.apply("linkis.ec.doris.host", "127.0.0.1");

public static final CommonVars<Integer> DORIS_HTTP_PORT =
CommonVars.apply("linkis.doris.http.port", 8030);
CommonVars.apply("linkis.ec.doris.http.port", 8030);

public static final CommonVars<Integer> DORIS_JDBC_PORT =
CommonVars.apply("linkis.doris.jdcb.port", 9030);
CommonVars.apply("linkis.ec.doris.jdcb.port", 9030);

public static final CommonVars<String> DORIS_DATABASE =
CommonVars.apply("linkis.doris.database", "");
CommonVars.apply("linkis.ec.doris.database", "");

public static final CommonVars<String> DORIS_TABLE = CommonVars.apply("linkis.doris.table", "");
public static final CommonVars<String> DORIS_TABLE =
CommonVars.apply("linkis.ec.doris.table", "");

public static final CommonVars<String> DORIS_USER_NAME =
CommonVars.apply("linkis.doris.username", "root");
CommonVars.apply("linkis.ec.doris.username", "root");

public static final CommonVars<String> DORIS_PASSWORD =
CommonVars.apply("linkis.doris.password", "");
CommonVars.apply("linkis.ec.doris.password", "");

public static final CommonVars<Boolean> DORIS_RECONNECT_ENABLED =
CommonVars.apply("linkis.doris.2pc.enabled", false, "two phase commit Whether to enable");
CommonVars.apply("linkis.ec.doris.2pc.enabled", false, "two phase commit Whether to enable");

public static final CommonVars<Boolean> DORIS_STRIP_OUTER_ARRAY =
CommonVars.apply(
"linkis.doris.strip.outer.array",
"linkis.ec.doris.strip.outer.array",
true,
"true indicates that the json data starts with an array object and flattens the array object, the default value is true, Refer to doris for strip_outer_array");
}

0 comments on commit 97d1f69

Please sign in to comment.