File tree Expand file tree Collapse file tree 3 files changed +6
-6
lines changed Expand file tree Collapse file tree 3 files changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -184,7 +184,7 @@ impl ExecutionPlan for TestInsertExec {
184184fn make_count_schema ( ) -> SchemaRef {
185185 Arc :: new ( Schema :: new ( vec ! [ Field :: new(
186186 "count" ,
187- DataType :: Int64 , // should return signed int for snowflake
187+ DataType :: UInt64 ,
188188 false ,
189189 ) ] ) )
190190}
Original file line number Diff line number Diff line change @@ -203,8 +203,7 @@ impl Display for InsertOp {
203203
204204fn make_count_schema ( ) -> DFSchemaRef {
205205 Arc :: new (
206- // should return signed int for snowflake
207- Schema :: new ( vec ! [ Field :: new( "count" , DataType :: Int64 , false ) ] )
206+ Schema :: new ( vec ! [ Field :: new( "count" , DataType :: UInt64 , false ) ] )
208207 . try_into ( )
209208 . unwrap ( ) ,
210209 )
Original file line number Diff line number Diff line change @@ -32,7 +32,7 @@ use crate::ExecutionPlanProperties;
3232
3333use arrow:: datatypes:: SchemaRef ;
3434use arrow:: record_batch:: RecordBatch ;
35- use arrow_array:: { ArrayRef , Int64Array } ;
35+ use arrow_array:: { ArrayRef , UInt64Array } ;
3636use arrow_schema:: { DataType , Field , Schema } ;
3737use datafusion_common:: { internal_err, Result } ;
3838use datafusion_execution:: TaskContext ;
@@ -271,15 +271,16 @@ impl ExecutionPlan for DataSinkExec {
271271/// +-------+,
272272/// ```
273273fn make_count_batch ( count : u64 ) -> RecordBatch {
274- let array = Arc :: new ( Int64Array :: from ( vec ! [ count as i64 ] ) ) as ArrayRef ;
274+ let array = Arc :: new ( UInt64Array :: from ( vec ! [ count] ) ) as ArrayRef ;
275+
275276 RecordBatch :: try_from_iter_with_nullable ( vec ! [ ( "count" , array, false ) ] ) . unwrap ( )
276277}
277278
278279fn make_count_schema ( ) -> SchemaRef {
279280 // Define a schema.
280281 Arc :: new ( Schema :: new ( vec ! [ Field :: new(
281282 "count" ,
282- DataType :: Int64 , // should return signed int for snowflake
283+ DataType :: UInt64 ,
283284 false ,
284285 ) ] ) )
285286}
You can’t perform that action at this time.
0 commit comments