@@ -421,7 +421,7 @@ impl Datum {
421
421
PrimitiveLiteral :: TimestampNs ( i64:: from_le_bytes ( bytes. try_into ( ) ?) )
422
422
}
423
423
PrimitiveType :: TimestamptzNs => {
424
- PrimitiveLiteral :: TimestampNs ( i64:: from_le_bytes ( bytes. try_into ( ) ?) )
424
+ PrimitiveLiteral :: TimestamptzNs ( i64:: from_le_bytes ( bytes. try_into ( ) ?) )
425
425
}
426
426
PrimitiveType :: String => {
427
427
PrimitiveLiteral :: String ( std:: str:: from_utf8 ( bytes) ?. to_string ( ) )
@@ -846,7 +846,7 @@ impl Datum {
846
846
/// use iceberg::spec::Datum;
847
847
/// let t = Datum::timestamptz_nanos(1000);
848
848
///
849
- /// assert_eq!(&format!("{t}"), "1970-01-01 00:00:00.001 UTC");
849
+ /// assert_eq!(&format!("{t}"), "1970-01-01 00:00:00.000001 UTC");
850
850
/// ```
851
851
pub fn timestamptz_nanos ( value : i64 ) -> Self {
852
852
Self {
@@ -1864,7 +1864,7 @@ impl Literal {
1864
1864
. to_string ( ) ,
1865
1865
) ) ,
1866
1866
PrimitiveLiteral :: TimestamptzNs ( val) => Ok ( JsonValue :: String (
1867
- timestamptz:: microseconds_to_datetimetz ( val)
1867
+ timestamptz:: nanoseconds_to_datetimetz ( val)
1868
1868
. format ( "%Y-%m-%dT%H:%M:%S%.f+00:00" )
1869
1869
. to_string ( ) ,
1870
1870
) ) ,
@@ -2049,7 +2049,7 @@ mod timestamptz {
2049
2049
pub ( crate ) fn nanoseconds_to_datetimetz ( nanos : i64 ) -> DateTime < Utc > {
2050
2050
let ( secs, rem) = ( nanos / 1_000_000_000 , nanos % 1_000_000_000 ) ;
2051
2051
2052
- DateTime :: from_timestamp ( secs, rem as u32 * 1_000 ) . unwrap ( )
2052
+ DateTime :: from_timestamp ( secs, rem as u32 ) . unwrap ( )
2053
2053
}
2054
2054
}
2055
2055
0 commit comments