add the convertion of bytes columns

StarRocks · Oct 9, 2021 · 4450cca · 4450cca
1 parent cbc93b9
commit 4450cca
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/...a/com/starrocks/connector/datax/plugin/writer/starrockswriter/StarRocksWriterOptions.java b/...a/com/starrocks/connector/datax/plugin/writer/starrockswriter/StarRocksWriterOptions.java
@@ -158,7 +158,6 @@ private void validateStreamLoadUrl() {
     private void validateRequired() {
        final String[] requiredOptionKeys = new String[]{
             KEY_USERNAME,
-            KEY_PASSWORD,
             KEY_DATABASE,
             KEY_TABLE,
             KEY_COLUMN,

diff --git a/.../starrocks/connector/datax/plugin/writer/starrockswriter/row/StarRocksBaseSerializer.java b/.../starrocks/connector/datax/plugin/writer/starrockswriter/row/StarRocksBaseSerializer.java
@@ -6,13 +6,21 @@
 public class StarRocksBaseSerializer {
 
     protected String fieldConvertion(Column col) {
-        if (null == col.getRawData()) {
+        if (null == col.getRawData() || Type.NULL == col.getType()) {
             return null;
         }
         if (Type.BOOL == col.getType()) {
             return String.valueOf(col.asLong());
         }
+        if (Type.BYTES == col.getType()) {
+            byte[] bts = (byte[])col.getRawData();
+            long value = 0;
+            for (int i = 0; i < bts.length; i++) {
+                value += (bts[bts.length - i - 1] & 0xffL) << (8 * i);
+            }
+            return String.valueOf(value);
+        }
         return col.asString();
     }
 
-}
+}