arrow2 0.18.0 release

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "arrow2"
-version = "0.17.4"
+version = "0.18.0"
 license = "Apache-2.0"
 description = "Unofficial implementation of Apache Arrow spec in safe Rust"
 homepage = "https://github.com/jorgecarleitao/arrow2"

src/io/csv/read_utils.rs

@@ -136,7 +136,7 @@ fn deserialize_datetime<T: chrono::TimeZone>(string: &str, tz: &T) -> Option<i64
             .to_datetime()
             .map(|x| x.naive_utc())
             .map(|x| tz.from_utc_datetime(&x))
-            .map(|x| x.timestamp_nanos())
+            .map(|x| x.timestamp_nanos_opt().unwrap())
             .ok()
     } else {
         None
@@ -228,7 +228,7 @@ pub(crate) fn deserialize_column<B: ByteRecordGeneric>(
         Timestamp(time_unit, None) => deserialize_primitive(rows, column, datatype, |bytes| {
             to_utf8(bytes)
                 .and_then(|x| x.parse::<chrono::NaiveDateTime>().ok())
-                .map(|x| x.timestamp_nanos())
+                .map(|x| x.timestamp_nanos_opt().unwrap())
                 .map(|x| match time_unit {
                     TimeUnit::Second => x / 1_000_000_000,
                     TimeUnit::Millisecond => x / 1_000_000,

src/io/odbc/read/deserialize.rs

@@ -264,12 +264,12 @@ fn timestamp_ms(timestamp: &odbc_api::sys::Timestamp) -> i64 {
 
 fn timestamp_us(timestamp: &odbc_api::sys::Timestamp) -> i64 {
     timestamp_to_naive(timestamp)
-        .map(|x| x.timestamp_nanos() / 1000)
+        .map(|x| x.timestamp_nanos_opt().unwrap() / 1000)
         .unwrap_or(0)
 }
 
 fn timestamp_ns(timestamp: &odbc_api::sys::Timestamp) -> i64 {
     timestamp_to_naive(timestamp)
-        .map(|x| x.timestamp_nanos())
+        .map(|x| x.timestamp_nanos_opt().unwrap())
         .unwrap_or(0)
 }

src/temporal_conversions.rs

@@ -363,7 +363,7 @@ pub fn utf8_to_timestamp_scalar<T: chrono::TimeZone>(
                 TimeUnit::Second => x.timestamp(),
                 TimeUnit::Millisecond => x.timestamp_millis(),
                 TimeUnit::Microsecond => x.timestamp_micros(),
-                TimeUnit::Nanosecond => x.timestamp_nanos(),
+                TimeUnit::Nanosecond => x.timestamp_nanos_opt().unwrap(),
             })
             .ok()
     } else {
@@ -390,7 +390,7 @@ pub fn utf8_to_naive_timestamp_scalar(value: &str, fmt: &str, tu: &TimeUnit) ->
             TimeUnit::Second => x.timestamp(),
             TimeUnit::Millisecond => x.timestamp_millis(),
             TimeUnit::Microsecond => x.timestamp_micros(),
-            TimeUnit::Nanosecond => x.timestamp_nanos(),
+            TimeUnit::Nanosecond => x.timestamp_nanos_opt().unwrap(),
         })
         .ok()
 }
@@ -515,8 +515,8 @@ pub fn add_naive_interval(timestamp: i64, time_unit: TimeUnit, interval: months_
     match time_unit {
         TimeUnit::Second => new_datetime_tz.timestamp_millis() / 1000,
         TimeUnit::Millisecond => new_datetime_tz.timestamp_millis(),
-        TimeUnit::Microsecond => new_datetime_tz.timestamp_nanos() / 1000,
-        TimeUnit::Nanosecond => new_datetime_tz.timestamp_nanos(),
+        TimeUnit::Microsecond => new_datetime_tz.timestamp_nanos_opt().unwrap() / 1000,
+        TimeUnit::Nanosecond => new_datetime_tz.timestamp_nanos_opt().unwrap(),
     }
 }
 
@@ -544,7 +544,7 @@ pub fn add_interval<T: chrono::TimeZone>(
     match time_unit {
         TimeUnit::Second => new_datetime_tz.timestamp_millis() / 1000,
         TimeUnit::Millisecond => new_datetime_tz.timestamp_millis(),
-        TimeUnit::Microsecond => new_datetime_tz.timestamp_nanos() / 1000,
-        TimeUnit::Nanosecond => new_datetime_tz.timestamp_nanos(),
+        TimeUnit::Microsecond => new_datetime_tz.timestamp_nanos_opt().unwrap() / 1000,
+        TimeUnit::Nanosecond => new_datetime_tz.timestamp_nanos_opt().unwrap(),
     }
 }