github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-02 07:40:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

add maxBatchRows maxBatchSize

Browse Source
This commit is contained in:
fariel 2021-04-30 10:55:02 +08:00
parent cac8434bbb
commit 342c044aaa
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/DorisWriterOptions.java
View File

@ -31,6 +31,8 @@ public class DorisWriterOptions implements Serializable {
private static final String KEY_PRE_SQL = "preSql";
private static final String KEY_POST_SQL = "postSql";
private static final String KEY_JDBC_URL = "jdbcUrl";
private static final String KEY_MAX_BATCH_ROWS = "maxBatchRows";
private static final String KEY_MAX_BATCH_SIZE = "maxBatchSize";
private static final String KEY_LOAD_URL = "loadUrl";
private static final String KEY_FLUSH_QUEUE_LENGTH = "flushQueueLength";
private static final String KEY_LOAD_PROPS = "loadProps";
@ -91,11 +93,13 @@ public class DorisWriterOptions implements Serializable {
}
public int getBatchRows() {
return BATCH_ROWS;
Integer rows = options.getInt(KEY_MAX_BATCH_ROWS);
return null == rows ? BATCH_ROWS : rows;
}
public long getBatchSize() {
return BATCH_BYTES;
Long size = options.getLong(KEY_MAX_BATCH_SIZE);
return null == size ? BATCH_BYTES : size;
}
public int getFlushQueueLength() {