Struct PhysicalMaterialize 

pub struct PhysicalMaterialize { /* private fields */ }

Trait Implementations

impl BaseOperator for PhysicalMaterialize

const OPERATOR_NAME: &str = "Materialize"

Name of the operator.

type OperatorState = MaterializeOperatorState

fn create_operator_state( &self, props: ExecutionProperties, ) -> Result<Self::OperatorState>

fn output_types(&self) -> &[DataType]

fn build_pipeline( operator: &PlannedOperator, children: &[PlannedOperatorWithChildren], props: ExecutionProperties, graph: &mut ExecutablePipelineGraph, current: &mut ExecutablePipeline, ) -> Result<()>

Pushes this operator on the current pipeline being built, handling the building of children as well.

impl Debug for PhysicalMaterialize

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

Formats the value using the given formatter.

impl Explainable for PhysicalMaterialize

fn explain_entry(&self, conf: ExplainConfig<'_>) -> ExplainEntry

Create an ExplainEntry for this node.

impl MaterializingOperator for PhysicalMaterialize

fn materialization_ref(&self) -> MaterializationRef

Return the materialization reference associated with this materialization.

impl PullOperator for PhysicalMaterialize

type PartitionPullState = MaterializePullPartitionState

fn create_partition_pull_states( &self, operator_state: &Self::OperatorState, _props: ExecutionProperties, partitions: usize, ) -> Result<Vec<Self::PartitionPullState>>

fn poll_pull( &self, cx: &mut Context<'_>, operator_state: &Self::OperatorState, state: &mut Self::PartitionPullState, output: &mut Batch, ) -> Result<PollPull>

impl PushOperator for PhysicalMaterialize

type PartitionPushState = MaterializePushPartitionState

fn create_partition_push_states( &self, operator_state: &Self::OperatorState, _props: ExecutionProperties, partitions: usize, ) -> Result<Vec<Self::PartitionPushState>>

fn poll_push( &self, _cx: &mut Context<'_>, operator_state: &Self::OperatorState, state: &mut Self::PartitionPushState, input: &mut Batch, ) -> Result<PollPush>

fn poll_finalize_push( &self, _cx: &mut Context<'_>, operator_state: &Self::OperatorState, state: &mut Self::PartitionPushState, ) -> Result<PollFinalize>