root
/
DataX
mirror of https://github.com/alibaba/DataX.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

修复hbase reader task 字段值为null的bug

This commit is contained in:
luolh 2020-09-09 15:09:04 +08:00
parent c83c5d1819
commit 2bd4b46fa2
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hbase20xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase20xsqlreader/HBase20xSQLReaderTask.java
View File

@ -86,16 +86,18 @@ public class HBase20xSQLReaderTask {
column = new LongColumn((Integer) value); column = new LongColumn((Integer) value);
break; break;
case Types.TINYINT: case Types.TINYINT:
column = new LongColumn(((Byte) value).longValue()); Byte aByte = (Byte) value;
column = new LongColumn(null == aByte ? null : aByte.longValue());
break; break;
case Types.SMALLINT: case Types.SMALLINT:
column = new LongColumn(((Short) value).longValue()); Short aShort = (Short) value;
column = new LongColumn(null == aShort ? null : aShort.longValue());
break; break;
case Types.BIGINT: case Types.BIGINT:
column = new LongColumn((Long) value); column = new LongColumn((Long) value);
break; break;
case Types.FLOAT: case Types.FLOAT:
column = new DoubleColumn((Float.valueOf(value.toString()))); column = new DoubleColumn(null == value ? null : (Float.valueOf(value.toString())));
break; break;
case Types.DECIMAL: case Types.DECIMAL:
column = new DoubleColumn((BigDecimal)value); column = new DoubleColumn((BigDecimal)value);