Struct datafusion::physical_plan::coalesce_batches::CoalesceBatchesExec [−][src]
pub struct CoalesceBatchesExec { /* fields omitted */ }
CoalesceBatchesExec combines small batches into larger batches for more efficient use of vectorized processing by upstream operators.
Implementations
impl CoalesceBatchesExec
[src]
impl CoalesceBatchesExec
[src]pub fn new(input: Arc<dyn ExecutionPlan>, target_batch_size: usize) -> Self
[src]
Create a new CoalesceBatchesExec
pub fn input(&self) -> &Arc<dyn ExecutionPlan>
[src]
The input plan
pub fn target_batch_size(&self) -> usize
[src]
Minimum number of rows for coalesces batches
Trait Implementations
impl ExecutionPlan for CoalesceBatchesExec
[src]
impl ExecutionPlan for CoalesceBatchesExec
[src]fn as_any(&self) -> &dyn Any
[src]
Return a reference to Any that can be used for downcasting
fn schema(&self) -> SchemaRef
[src]
Get the schema for this execution plan
fn children(&self) -> Vec<Arc<dyn ExecutionPlan>>
[src]
fn output_partitioning(&self) -> Partitioning
[src]
Get the output partitioning of this plan
fn with_new_children(
&self,
children: Vec<Arc<dyn ExecutionPlan>>
) -> Result<Arc<dyn ExecutionPlan>>
[src]
&self,
children: Vec<Arc<dyn ExecutionPlan>>
) -> Result<Arc<dyn ExecutionPlan>>
fn execute<'life0, 'async_trait>(
&'life0 self,
partition: usize
) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
partition: usize
) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn required_child_distribution(&self) -> Distribution
[src]
fn metrics(&self) -> HashMap<String, SQLMetric>
[src]
Auto Trait Implementations
impl !RefUnwindSafe for CoalesceBatchesExec
impl !RefUnwindSafe for CoalesceBatchesExec
impl Send for CoalesceBatchesExec
impl Send for CoalesceBatchesExec
impl Sync for CoalesceBatchesExec
impl Sync for CoalesceBatchesExec
impl Unpin for CoalesceBatchesExec
impl Unpin for CoalesceBatchesExec
impl !UnwindSafe for CoalesceBatchesExec
impl !UnwindSafe for CoalesceBatchesExec