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

optimize columns with backquotes

Browse Source
This commit is contained in:
hffariel 2021-10-14 21:48:44 +08:00
parent 4450ccadd8
commit a3aa8e31eb
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksStreamLoadVisitor.java
View File

@ -26,6 +26,7 @@ import org.slf4j.LoggerFactory;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.stream.Collectors;
public class StarRocksStreamLoadVisitor { public class StarRocksStreamLoadVisitor {
@ -137,7 +138,7 @@ public class StarRocksStreamLoadVisitor {
HttpPut httpPut = new HttpPut(loadUrl); HttpPut httpPut = new HttpPut(loadUrl);
List<String> cols = writerOptions.getColumns(); List<String> cols = writerOptions.getColumns();
if (null != cols && !cols.isEmpty()) { if (null != cols && !cols.isEmpty()) {
httpPut.setHeader("columns", String.join(",", cols)); httpPut.setHeader("columns", String.join(",", cols.stream().map(f -> String.format("`%s`", f)).collect(Collectors.toList())));
} }
if (null != writerOptions.getLoadProps()) { if (null != writerOptions.getLoadProps()) {
for (Map.Entry<String, Object> entry : writerOptions.getLoadProps().entrySet()) { for (Map.Entry<String, Object> entry : writerOptions.getLoadProps().entrySet()) {