Reducing to the numeric POJO property to DOUBLE

Author: hemanthsavasere

fluss-client/src/main/java/org/apache/fluss/client/converter/PojoToRowConverter.java

@@ -420,23 +420,8 @@ private static int truncateNanos(int nanos, int precision) {
         if (v == null) {
             return null;
         }
-        if (v instanceof Double) {
-            return (Double) v;
-        }
-        if (v instanceof Float) {
-            return ((Float) v).doubleValue(); // float -> double widening
-        }
-        if (v instanceof Long) {
-            return ((Long) v).doubleValue(); // long -> double widening
-        }
-        if (v instanceof Integer) {
-            return ((Integer) v).doubleValue(); // int -> double widening
-        }
-        if (v instanceof Short) {
-            return ((Short) v).doubleValue(); // short -> double widening
-        }
-        if (v instanceof Byte) {
-            return ((Byte) v).doubleValue(); // byte -> double widening
+        if (v instanceof Number) {
+            return ((Number) v).doubleValue();
         }
         throw new IllegalArgumentException(
                 String.format(

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/PojoToRowConverter.java

@@ -485,23 +485,8 @@ private static Object convertToDouble(Field field, Object value)
         if (value == null) {
             return null;
         }
-        if (value instanceof Double) {
-            return value;
-        }
-        if (value instanceof Float) {
-            return ((Float) value).doubleValue();
-        }
-        if (value instanceof Long) {
-            return ((Long) value).doubleValue();
-        }
-        if (value instanceof Integer) {
-            return ((Integer) value).doubleValue();
-        }
-        if (value instanceof Short) {
-            return ((Short) value).doubleValue();
-        }
-        if (value instanceof Byte) {
-            return ((Byte) value).doubleValue();
+        if (value instanceof Number) {
+            return ((Number) value).doubleValue();
         }
         throw new IllegalArgumentException(
                 "Field " + field.getName() + " cannot be converted to DOUBLE");