Module coalesce 

BatchCoalescer concatenates multiple [RecordBatch]es after operations such as filter and take.

Re-exports

use crate::filter::FilterBuilder; 🔒

use crate::filter::FilterPredicate; 🔒

use crate::filter::FilterSelection; 🔒

use crate::interleave::interleave_record_batch; 🔒

use crate::take::take_record_batch; 🔒

use arrow_array::types::BinaryViewType; 🔒

use arrow_array::types::GenericBinaryType; 🔒

use arrow_array::types::GenericStringType; 🔒

use arrow_array::types::StringViewType; 🔒

use arrow_array::Array; 🔒

use arrow_array::ArrayRef; 🔒

use arrow_array::BooleanArray; 🔒

use arrow_array::RecordBatch; 🔒

use arrow_array::downcast_primitive; 🔒

use arrow_schema::ArrowError; 🔒

use arrow_schema::DataType; 🔒

use arrow_schema::SchemaRef; 🔒

use std::collections::VecDeque; 🔒

use std::sync::Arc; 🔒

use boolean::InProgressBooleanArray; 🔒

use byte::InProgressByteArray; 🔒

use byte_view::InProgressByteViewArray; 🔒

use dictionary::create_in_progress_dictionary; 🔒

use fixed_size_binary::InProgressFixedSizeBinaryArray; 🔒

use generic::GenericInProgressArray; 🔒

use list::InProgressListArray; 🔒

use primitive::InProgressPrimitiveArray; 🔒

Modules

boolean 🔒

byte 🔒

byte_view 🔒

dictionary 🔒

fixed_size_binary 🔒

generic 🔒

list 🔒

primitive 🔒

Structs

BatchCoalescer

Concatenate multiple [RecordBatch]es

Constants

BYTE_ARRAY_DIRECT_COPY_MAX_SELECTIVITY_DENOMINATOR 🔒

SPARSE_FILTER_COPY_MAX_SELECTIVITY_DENOMINATOR 🔒

Maximum selected row fraction for the fused sparse-filter copy path.

Traits

InProgressArray 🔒

Incrementally builds up arrays

Functions

check_filter_len 🔒

Return an error if filter is longer than the source array it is applied to.

create_in_progress_array 🔒

Return a new InProgressArray for the given data type

has_sparse_filter_copy 🔒

should_use_byte_array_direct_copy 🔒

should_use_sparse_filter_copy 🔒