0004276: HBase data loader support for null values in source

JumpMind · Feb 6, 2020 · fa3d54f · fa3d54f
1 parent 4b34101
commit fa3d54f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/io/HbaseDatabaseWriter.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/io/HbaseDatabaseWriter.java
@@ -4,6 +4,7 @@
 import java.util.ArrayList;
 import java.util.List;
 
+import org.apache.commons.lang.StringUtils;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.hbase.HBaseConfiguration;
@@ -65,7 +66,8 @@ protected LoadStatus put(CsvData data) {
                     byte[] columnFamily = split[0].getBytes();
                     byte[] columnName = split[1].getBytes();
 
-                    put.addColumn(columnFamily, columnName, values[i].getBytes());
+                    byte[] value = StringUtils.isEmpty(values[i]) ? new byte[0] : values[i].getBytes();
+                    put.addColumn(columnFamily, columnName, value);
                     putList.add(put);
                 }
             }