Enum RepartitionExecState 

enum RepartitionExecState {
    NotInitialized,
    InputStreamsInitialized(Vec<(SendableRecordBatchStream, RepartitionMetrics)>),
    ConsumingInputStreams(ConsumingInputStreamsState),
}

Inner state of RepartitionExec.

Variants

NotInitialized

Not initialized yet. This is the default state stored in the RepartitionExec node upon instantiation.

InputStreamsInitialized(Vec<(SendableRecordBatchStream, RepartitionMetrics)>)

Input streams are initialized, but they are still not being consumed. The node transitions to this state when the arrow’s RecordBatch stream is created in RepartitionExec::execute(), but before any message is polled.

ConsumingInputStreams(ConsumingInputStreamsState)

The input streams are being consumed. The node transitions to this state when the first message in the arrow’s RecordBatch stream is consumed.

Implementations

impl RepartitionExecState

fn ensure_input_streams_initialized( &mut self, input: Arc<dyn ExecutionPlan>, metrics: ExecutionPlanMetricsSet, output_partitions: usize, ctx: Arc<TaskContext>, ) -> Result<()>

fn consume_input_streams( &mut self, input: Arc<dyn ExecutionPlan>, metrics: ExecutionPlanMetricsSet, partitioning: Partitioning, preserve_order: bool, name: String, context: Arc<TaskContext>, ) -> Result<&mut ConsumingInputStreamsState>

Trait Implementations

impl Debug for RepartitionExecState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for RepartitionExecState

fn default() -> RepartitionExecState

Returns the “default value” for a type.