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

change the link charactor of the stream load label

Browse Source
This commit is contained in:
hffariel 2022-02-14 20:15:14 +08:00
parent 0554bd1bea
commit 721ed5136d
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 DOT = "."; private static final String HYPHEN = "-";
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(DOT); sb.append(writerOptions.getLabelPrefix()).append(HYPHEN);
} }
return sb.append(writerOptions.getDatabase()) return sb.append(writerOptions.getDatabase())
.append(DOT) .append(HYPHEN)
.append(writerOptions.getTable()) .append(writerOptions.getTable())
.append(DOT) .append(HYPHEN)
.append(UUID.randomUUID().toString()) .append(UUID.randomUUID().toString())
.toString(); .toString();
} }