polars_compute/gather/
structure.rs

1// Licensed to the Apache Software Foundation (ASF) under one
2// or more contributor license agreements.  See the NOTICE file
3// distributed with this work for additional information
4// regarding copyright ownership.  The ASF licenses this file
5// to you under the Apache License, Version 2.0 (the
6// "License"); you may not use this file except in compliance
7// with the License.  You may obtain a copy of the License at
8//
9//   http://www.apache.org/licenses/LICENSE-2.0
10//
11// Unless required by applicable law or agreed to in writing,
12// software distributed under the License is distributed on an
13// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14// KIND, either express or implied.  See the License for the
15// specific language governing permissions and limitations
16// under the License.
17
18use arrow::array::{Array, StructArray};
19use arrow::compute::utils::combine_validities_and;
20use arrow::datatypes::IdxArr;
21
22pub(super) unsafe fn take_unchecked(array: &StructArray, indices: &IdxArr) -> StructArray {
23    let values: Vec<Box<dyn Array>> = array
24        .values()
25        .iter()
26        .map(|a| super::take_unchecked(a.as_ref(), indices))
27        .collect();
28
29    let validity = array
30        .validity()
31        .map(|b| super::bitmap::take_bitmap_nulls_unchecked(b, indices));
32    let validity = combine_validities_and(validity.as_ref(), indices.validity());
33    StructArray::new(array.dtype().clone(), indices.len(), values, validity)
34}
polars_compute/gather/structure.rs

polars_compute/gather/
structure.rs
