Struct spark_connect_rs::plan::LogicalPlanBuilder

pub struct LogicalPlanBuilder {
    pub relation: Relation,
    pub plan_id: i64,
}

Implements a struct to hold the current Relation which represents an unresolved Logical Plan

Fields

relation: Relation

A Relation object that contains the unresolved logical plan

plan_id: i64

Implementations

impl LogicalPlanBuilder

pub fn new(relation: Relation) -> LogicalPlanBuilder

Create a new Logical Plan from an initial spark::Relation

pub fn relation_input(self) -> Option<Box<Relation>>

pub fn build_plan_root(self) -> Plan

Build the Spark spark::Plan for a Relation

pub fn build_plan_cmd(command_type: CommandType) -> Plan

Build the Spark spark::Plan for a spark::command::CommandType

pub fn from(rel_type: RelType) -> LogicalPlanBuilder

Create a relation from an existing LogicalPlanBuilder this will add additional actions to the Relation

pub fn select<T: ToVecExpr>(&mut self, cols: T) -> LogicalPlanBuilder

pub fn select_expr(&mut self, cols: Vec<&str>) -> LogicalPlanBuilder

pub fn filter<T: ToFilterExpr>(&mut self, condition: T) -> LogicalPlanBuilder

pub fn contains(&mut self, condition: Column) -> LogicalPlanBuilder

pub fn limit(&mut self, limit: i32) -> LogicalPlanBuilder

pub fn drop_duplicates(&mut self, cols: Option<Vec<&str>>) -> LogicalPlanBuilder

pub fn with_columns_renamed( &mut self, cols: HashMap<String, String> ) -> LogicalPlanBuilder

pub fn drop(&mut self, cols: Vec<String>) -> LogicalPlanBuilder

pub fn sample( &mut self, lower_bound: f64, upper_bound: f64, with_replacement: Option<bool>, seed: Option<i64> ) -> LogicalPlanBuilder

pub fn repartition( &mut self, num_partitions: i32, shuffle: Option<bool> ) -> LogicalPlanBuilder

pub fn offset(&mut self, num: i32) -> LogicalPlanBuilder

pub fn sort(&mut self, cols: Vec<Column>) -> LogicalPlanBuilder

Trait Implementations

impl Clone for LogicalPlanBuilder

fn clone(&self) -> LogicalPlanBuilder

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LogicalPlanBuilder

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

Formats the value using the given formatter.