converted to Int64

Author: nikhilsinhaparseable

src/event/format/json.rs

@@ -174,14 +174,11 @@ fn fields_mismatch(schema: &[Arc<Field>], body: &Value, schema_version: SchemaVe
 fn valid_type(data_type: &DataType, value: &Value, schema_version: SchemaVersion) -> bool {
     match data_type {
         DataType::Boolean => value.is_boolean(),
-        DataType::Int8 | DataType::Int16 | DataType::Int32 | DataType::Int64 => value.is_i64(),
+        DataType::Int8 | DataType::Int16 | DataType::Int32 => value.is_i64(),
         DataType::UInt8 | DataType::UInt16 | DataType::UInt32 | DataType::UInt64 => value.is_u64(),
-        DataType::Float16 | DataType::Float32 => value.is_f64(),
+        DataType::Float16 | DataType::Float32 | DataType::Float64 => value.is_f64(),
         // All numbers can be cast as Float64 from schema version v1
-        DataType::Float64 if schema_version == SchemaVersion::V1 => {
-            value.is_number() || is_parsable_as_number(value)
-        }
-        DataType::Float64 if schema_version != SchemaVersion::V1 => value.is_f64(),
+        DataType::Int64 => value.is_i64() || is_parsable_as_number(value),
         DataType::Utf8 => value.is_string(),
         DataType::List(field) => {
             let data_type = field.data_type();
@@ -232,5 +229,5 @@ pub fn is_parsable_as_number(value: &Value) -> bool {
     let Value::String(s) = value else {
         return false;
     };
-    s.parse::<f64>().is_ok()
+    s.parse::<i64>().is_ok()
 }

src/event/format/mod.rs

@@ -318,18 +318,18 @@ pub fn override_data_type(
                                 .get(field_name)
                                 .unwrap()
                                 .data_type()
-                                == &DataType::Float64
+                                == &DataType::Int64
                             && field.data_type() == &DataType::Utf8
-                            && s.parse::<f64>().is_ok()) =>
+                            && s.parse::<i64>().is_ok()) =>
                 {
                     // Update the field's data type to Float64
-                    Field::new(field_name, DataType::Float64, true)
+                    Field::new(field_name, DataType::Int64, true)
                 }
 
                 // in V1 for new fields in json with inferred type number, cast as float64.
-                (SchemaVersion::V1, Some(Value::Number(_))) if field.data_type().is_numeric() => {
+                (SchemaVersion::V1, Some(Value::Number(_))) if field.data_type().is_integer() => {
                     // Update the field's data type to Float64
-                    Field::new(field_name, DataType::Float64, true)
+                    Field::new(field_name, DataType::Int64, true)
                 }
                 // Return the original field if no update is needed
                 _ => Field::new(field_name, field.data_type().clone(), true),