Skip to content

Commit 94fe993

Browse files
committed
Add entry to Cargo.toml
1 parent d1b8886 commit 94fe993

File tree

2 files changed

+11
-2
lines changed

2 files changed

+11
-2
lines changed

arrow/Cargo.toml

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -172,7 +172,6 @@ name = "coalesce_kernels"
172172
harness = false
173173
required-features = ["test_utils"]
174174

175-
176175
[[bench]]
177176
name = "take_kernels"
178177
harness = false
@@ -311,6 +310,11 @@ name = "lexsort"
311310
harness = false
312311
required-features = ["test_utils"]
313312

313+
[[bench]]
314+
name = "nullif_kernel"
315+
harness = false
316+
required-features = ["test_utils"]
317+
314318
[[test]]
315319
name = "csv"
316320
required-features = ["csv", "chrono-tz"]

parquet/src/arrow/arrow_reader/selection.rs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ pub enum RowSelectionPolicy {
4444

4545
impl Default for RowSelectionPolicy {
4646
fn default() -> Self {
47-
Self::Auto { threshold: 32 }
47+
Self::Auto { threshold: 16 }
4848
}
4949
}
5050

@@ -146,6 +146,7 @@ impl RowSelection {
146146
/// # Panic
147147
///
148148
/// Panics if any of the [`BooleanArray`] contain nulls
149+
#[inline(never)]
149150
pub fn from_filters(filters: &[BooleanArray]) -> Self {
150151
let mut next_offset = 0;
151152
let total_rows = filters.iter().map(|x| x.len()).sum();
@@ -161,6 +162,7 @@ impl RowSelection {
161162
}
162163

163164
/// Creates a [`RowSelection`] from an iterator of consecutive ranges to keep
165+
#[inline(never)]
164166
pub fn from_consecutive_ranges<I: Iterator<Item = Range<usize>>>(
165167
ranges: I,
166168
total_rows: usize,
@@ -201,6 +203,7 @@ impl RowSelection {
201203
/// Note: this method does not make any effort to combine consecutive ranges, nor coalesce
202204
/// ranges that are close together. This is instead delegated to the IO subsystem to optimise,
203205
/// e.g. [`ObjectStore::get_ranges`](object_store::ObjectStore::get_ranges)
206+
#[inline(never)]
204207
pub fn scan_ranges(&self, page_locations: &[PageLocation]) -> Vec<Range<u64>> {
205208
let mut ranges: Vec<Range<u64>> = vec![];
206209
let mut row_offset = 0;
@@ -342,6 +345,7 @@ impl RowSelection {
342345
/// Panics if `other` does not have a length equal to the number of rows selected
343346
/// by this RowSelection
344347
///
348+
#[inline(never)]
345349
pub fn and_then(&self, other: &Self) -> Self {
346350
let mut selectors = vec![];
347351
let mut first = self.selectors.iter().cloned().peekable();
@@ -923,6 +927,7 @@ impl RowSelectionCursor {
923927
}
924928
}
925929

930+
#[inline(never)]
926931
fn boolean_mask_from_selectors(selectors: &[RowSelector]) -> BooleanBuffer {
927932
let total_rows: usize = selectors.iter().map(|s| s.row_count).sum();
928933
let mut builder = BooleanBufferBuilder::new(total_rows);

0 commit comments

Comments
 (0)