Skip to content

Commit 9957cfd

Browse files
author
dapeng
committed
支持decimal类型
1 parent f17dc3f commit 9957cfd

File tree

1 file changed

+6
-3
lines changed
  • hbase/hbase-side/hbase-side-core/src/main/java/com/dtstack/flink/sql/side/hbase/utils

1 file changed

+6
-3
lines changed

hbase/hbase-side/hbase-side-core/src/main/java/com/dtstack/flink/sql/side/hbase/utils/HbaseUtils.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -66,9 +66,12 @@ public static Object convertByte(byte[] hbaseData, String type){
6666

6767
case "double":
6868
return Bytes.toDouble(hbaseData);
69-
69+
case "decimal":
70+
return Bytes.toBigDecimal(hbaseData);
71+
default:
72+
throw new RuntimeException("not support type of " + type);
7073
}
71-
72-
throw new RuntimeException("not support type of " + type);
7374
}
75+
76+
7477
}

0 commit comments

Comments
 (0)