github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-03 06:51:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

change the linking charactor of stream load label

Browse Source
This commit is contained in:
hffariel 2022-02-14 19:23:20 +08:00
parent a1bf9baa3e
commit 0554bd1bea
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksWriterManager.java
View File

@ -24,7 +24,7 @@ public class StarRocksWriterManager {
private final StarRocksStreamLoadVisitor starrocksStreamLoadVisitor; private final StarRocksStreamLoadVisitor starrocksStreamLoadVisitor;
private final StarRocksWriterOptions writerOptions; private final StarRocksWriterOptions writerOptions;
private static final String UNDERSCORE = "_"; private static final String DOT = ".";
private final List<byte[]> buffer = new ArrayList<>(); private final List<byte[]> buffer = new ArrayList<>();
private int batchCount = 0; private int batchCount = 0;
@ -123,12 +123,12 @@ public class StarRocksWriterManager {
public String createBatchLabel() { public String createBatchLabel() {
StringBuilder sb = new StringBuilder(); StringBuilder sb = new StringBuilder();
if (!Strings.isNullOrEmpty(writerOptions.getLabelPrefix())) { if (!Strings.isNullOrEmpty(writerOptions.getLabelPrefix())) {
sb.append(writerOptions.getLabelPrefix()).append(UNDERSCORE); sb.append(writerOptions.getLabelPrefix()).append(DOT);
} }
return sb.append(writerOptions.getDatabase()) return sb.append(writerOptions.getDatabase())
.append(UNDERSCORE) .append(DOT)
.append(writerOptions.getTable()) .append(writerOptions.getTable())
.append(UNDERSCORE) .append(DOT)
.append(UUID.randomUUID().toString()) .append(UUID.randomUUID().toString())
.toString(); .toString();
} }