Struct datafusion_federation::FederatedPlanNode

pub struct FederatedPlanNode { /* private fields */ }

Implementations

impl FederatedPlanNode

pub fn new(plan: LogicalPlan, planner: Arc<dyn FederationPlanner>) -> Self

pub fn plan(&self) -> &LogicalPlan

Trait Implementations

impl Debug for FederatedPlanNode

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

Formats the value using the given formatter.

impl Hash for FederatedPlanNode

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for FederatedPlanNode

fn eq(&self, other: &FederatedPlanNode) -> bool

Comparing name, args and return_type

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl UserDefinedLogicalNodeCore for FederatedPlanNode

fn name(&self) -> &str

Return the plan’s name.

fn inputs(&self) -> Vec<&LogicalPlan>

Return the logical plan’s inputs.

fn schema(&self) -> &DFSchemaRef

Return the output schema of this logical plan node.

fn expressions(&self) -> Vec<Expr>

Returns all expressions in the current logical plan node. This should not include expressions of any inputs (aka non-recursively). These expressions are used for optimizer passes and rewrites.

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

Write a single line, human readable string to f for use in explain plan.

fn from_template(&self, exprs: &[Expr], inputs: &[LogicalPlan]) -> Self

Create a new ExtensionPlanNode with the specified children and expressions. This function is used during optimization when the plan is being rewritten and a new instance of the ExtensionPlanNode must be created.

fn prevent_predicate_push_down_columns(&self) -> HashSet<String>

A list of output columns (e.g. the names of columns in self.schema()) for which predicates can not be pushed below this node without changing the output.

impl Eq for FederatedPlanNode