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

remove db and table info from stream load label

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

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

@ -24,7 +24,6 @@ public class StarRocksWriterManager {
private final StarRocksStreamLoadVisitor starrocksStreamLoadVisitor; private final StarRocksStreamLoadVisitor starrocksStreamLoadVisitor;
private final StarRocksWriterOptions writerOptions; private final StarRocksWriterOptions writerOptions;
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,13 +122,9 @@ 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(HYPHEN); sb.append(writerOptions.getLabelPrefix());
} }
return sb.append(writerOptions.getDatabase()) return sb.append(UUID.randomUUID().toString())
.append(HYPHEN)
.append(writerOptions.getTable())
.append(HYPHEN)
.append(UUID.randomUUID().toString())
.toString(); .toString();
} }