lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

when column type is decimal, should add precision and scale (#753)

Browse Source
This commit is contained in:
Thinking Chen
2019-07-09 07:13:22 +08:00
committed by vinoth chandar
parent 9f18a1ca80
commit 62ecb2da62
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
hoodie-hive/src/main/java/com/uber/hoodie/hive/HoodieHiveClient.java
View File

@@ -285,6 +285,11 @@ public class HoodieHiveClient {
while (result.next()) { while (result.next()) {
String columnName = result.getString(4); String columnName = result.getString(4);
String columnType = result.getString(6); String columnType = result.getString(6);
if ("DECIMAL".equals(columnType)) {
int columnSize = result.getInt("COLUMN_SIZE");
int decimalDigits = result.getInt("DECIMAL_DIGITS");
columnType += String.format("(%s,%s)", columnSize, decimalDigits);
}
schema.put(columnName, columnType); schema.put(columnName, columnType);
} }
return schema; return schema;