File tree Expand file tree Collapse file tree
datafusion/physical-plan/src/joins/hash_join Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -3058,7 +3058,11 @@ fn deduplicate_view_array_buffers<T: ByteViewType>(
30583058 // been remapped to point at the logically equivalent deduplicated buffer in
30593059 // `unique_buffers`, preserving the original byte offsets and lengths.
30603060 unsafe {
3061- GenericByteViewArray :: < T > :: new_unchecked ( new_views_buffer, unique_buffers. into ( ) , nulls)
3061+ GenericByteViewArray :: < T > :: new_unchecked (
3062+ new_views_buffer,
3063+ unique_buffers. into ( ) ,
3064+ nulls,
3065+ )
30623066 }
30633067}
30643068
@@ -7736,11 +7740,11 @@ mod tests {
77367740 Arc :: new ( Schema :: new ( vec ! [ Field :: new( "s" , DataType :: Utf8View , true ) ] ) ) ;
77377741
77387742 let batch1 =
7739- RecordBatch :: try_new ( schema . clone ( ) , vec ! [ Arc :: new( base_array. clone( ) ) ] ) ?;
7743+ RecordBatch :: try_new ( Arc :: clone ( & schema ) , vec ! [ Arc :: new( base_array. clone( ) ) ] ) ?;
77407744 let batch2 =
7741- RecordBatch :: try_new ( schema . clone ( ) , vec ! [ Arc :: new( base_array. clone( ) ) ] ) ?;
7745+ RecordBatch :: try_new ( Arc :: clone ( & schema ) , vec ! [ Arc :: new( base_array. clone( ) ) ] ) ?;
77427746 let batch3 =
7743- RecordBatch :: try_new ( schema . clone ( ) , vec ! [ Arc :: new( base_array. clone( ) ) ] ) ?;
7747+ RecordBatch :: try_new ( Arc :: clone ( & schema ) , vec ! [ Arc :: new( base_array. clone( ) ) ] ) ?;
77447748
77457749 // Before deduplication, concat_batches puts 3 duplicate buffer references in data_buffers
77467750 let concatenated_raw =
You can’t perform that action at this time.
0 commit comments