@@ -239,8 +239,12 @@ impl TransformFunction for Bucket {
239239 ( PrimitiveType :: Time , PrimitiveLiteral :: Long ( v) ) => self . bucket_time ( * v) ,
240240 ( PrimitiveType :: Timestamp , PrimitiveLiteral :: Long ( v) ) => self . bucket_timestamp ( * v) ,
241241 ( PrimitiveType :: Timestamptz , PrimitiveLiteral :: Long ( v) ) => self . bucket_timestamp ( * v) ,
242- ( PrimitiveType :: TimestampNs , PrimitiveLiteral :: Long ( v) ) => self . bucket_timestamp ( * v) ,
243- ( PrimitiveType :: TimestamptzNs , PrimitiveLiteral :: Long ( v) ) => self . bucket_timestamp ( * v) ,
242+ ( PrimitiveType :: TimestampNs , PrimitiveLiteral :: Long ( v) ) => {
243+ self . bucket_timestamp ( * v / 1000 )
244+ }
245+ ( PrimitiveType :: TimestamptzNs , PrimitiveLiteral :: Long ( v) ) => {
246+ self . bucket_timestamp ( * v / 1000 )
247+ }
244248 ( PrimitiveType :: String , PrimitiveLiteral :: String ( v) ) => self . bucket_str ( v. as_str ( ) ) ,
245249 ( PrimitiveType :: Uuid , PrimitiveLiteral :: UInt128 ( v) ) => {
246250 self . bucket_bytes ( uuid:: Uuid :: from_u128 ( * v) . as_ref ( ) )
@@ -926,7 +930,7 @@ mod test {
926930 . transform_literal( & Datum :: timestamp_nanos( ns_value) )
927931 . unwrap( )
928932 . unwrap( ) ,
929- Datum :: int( 79 )
933+ Datum :: int( 7 )
930934 ) ;
931935 }
932936
@@ -939,7 +943,7 @@ mod test {
939943 . transform_literal( & Datum :: timestamptz_nanos( ns_value) )
940944 . unwrap( )
941945 . unwrap( ) ,
942- Datum :: int( 79 )
946+ Datum :: int( 7 )
943947 ) ;
944948 }
945949
0 commit comments