Cast BigDecimal to double, BigInteger to long or text(#6612)

apache · Apr 4, 2020 · 6905380 · 6905380
1 parent 77663ac
commit 6905380
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/...-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericJsonRecord.java b/...-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericJsonRecord.java
@@ -55,6 +55,14 @@ public Object getField(String fieldName) {
             return new GenericJsonRecord(schemaVersion, fields, fn);
         } else if (fn.isBoolean()) {
             return fn.asBoolean();
+        } else if (fn.isFloatingPointNumber()) {
+            return fn.asDouble();
+        } else if (fn.isBigInteger()) {
+            if (fn.canConvertToLong()) {
+                return fn.asLong();
+            } else {
+                return fn.asText();
+            }
         } else if (fn.isNumber()) {
             return fn.numberValue();
         } else {