Class SparkToEnumerableConverter

All Implemented Interfaces:
Cloneable, EnumerableRel, RelOptNode, Converter, PhysicalNode, RelNode

public class SparkToEnumerableConverter extends ConverterImpl implements EnumerableRel
Relational expression that converts input of Spark convention into EnumerableConvention.

Concretely, this means calling the AbstractJavaRDDLike.collect() method of an RDD and converting it to enumerable.

  • Constructor Details

  • Method Details

    • copy

      public RelNode copy(RelTraitSet traitSet, List<RelNode> inputs)
      Description copied from interface: RelNode
      Creates a copy of this relational expression, perhaps changing traits and inputs.

      Sub-classes with other important attributes are encouraged to create variants of this method with more parameters.

      Specified by:
      copy in interface RelNode
      copy in class AbstractRelNode
      traitSet - Trait set
      inputs - Inputs
      Copy of this relational expression, substituting traits and inputs
    • computeSelfCost

      public @Nullable RelOptCost computeSelfCost(RelOptPlanner planner, RelMetadataQuery mq)
      Description copied from interface: RelNode
      Returns the cost of this plan (not including children). The base implementation throws an error; derived classes should override.

      NOTE jvs 29-Mar-2006: Don't call this method directly. Instead, use RelMetadataQuery.getNonCumulativeCost(org.apache.calcite.rel.RelNode), which gives plugins a chance to override the rel's default ideas about cost.

      Specified by:
      computeSelfCost in interface RelNode
      computeSelfCost in class ConverterImpl
      planner - Planner for cost calculation
      mq - Metadata query
      Cost of this plan (not including children)
    • implement

      Description copied from interface: EnumerableRel
      Creates a plan for this expression according to a calling convention.
      Specified by:
      implement in interface EnumerableRel
      implementor - Implementor
      pref - Preferred representation for rows in result expression
      Plan for this expression according to a calling convention