@@ -1514,8 +1514,10 @@ mod tests {
15141514 let mut partitions: Vec < Arc < dyn PartitionStream > > = Vec :: new ( ) ;
15151515 for p in 0 ..num_partitions {
15161516 let values = pseudo_random_i64s ( rows_per_partition, ( p * rows_per_partition) as i64 ) ;
1517- let batch =
1518- RecordBatch :: try_new ( Arc :: clone ( & schema) , vec ! [ Arc :: new( Int64Array :: from( values) ) ] ) ?;
1517+ let batch = RecordBatch :: try_new (
1518+ Arc :: clone ( & schema) ,
1519+ vec ! [ Arc :: new( Int64Array :: from( values) ) ] ,
1520+ ) ?;
15191521
15201522 partitions. push ( Arc :: new ( StaticPartitionStream {
15211523 schema : Arc :: clone ( & schema) ,
@@ -1631,8 +1633,10 @@ mod tests {
16311633 let mut partitions: Vec < Arc < dyn PartitionStream > > = Vec :: new ( ) ;
16321634 for p in 0 ..num_partitions {
16331635 let values = pseudo_random_i64s ( rows_per_partition, ( p * rows_per_partition) as i64 ) ;
1634- let batch =
1635- RecordBatch :: try_new ( Arc :: clone ( & schema) , vec ! [ Arc :: new( Int64Array :: from( values) ) ] ) ?;
1636+ let batch = RecordBatch :: try_new (
1637+ Arc :: clone ( & schema) ,
1638+ vec ! [ Arc :: new( Int64Array :: from( values) ) ] ,
1639+ ) ?;
16361640
16371641 partitions. push ( Arc :: new ( StaticPartitionStream {
16381642 schema : Arc :: clone ( & schema) ,
@@ -1752,8 +1756,10 @@ mod tests {
17521756 let mut partitions: Vec < Arc < dyn PartitionStream > > = Vec :: new ( ) ;
17531757 for p in 0 ..num_partitions {
17541758 let values = pseudo_random_i64s ( rows_per_partition, ( p * rows_per_partition) as i64 ) ;
1755- let batch =
1756- RecordBatch :: try_new ( Arc :: clone ( & schema) , vec ! [ Arc :: new( Int64Array :: from( values) ) ] ) ?;
1759+ let batch = RecordBatch :: try_new (
1760+ Arc :: clone ( & schema) ,
1761+ vec ! [ Arc :: new( Int64Array :: from( values) ) ] ,
1762+ ) ?;
17571763
17581764 partitions. push ( Arc :: new ( StaticPartitionStream {
17591765 schema : Arc :: clone ( & schema) ,
0 commit comments