Package org.apache.calcite.adapter.spark

Interface SparkRel

All Superinterfaces:

Cloneable, RelNode, RelOptNode

All Known Implementing Classes:

EnumerableToSparkConverter, JdbcToSparkConverter, SparkRules.SparkCalc, SparkRules.SparkValues

public interface SparkRel
extends RelNode

Relational expression that uses Spark calling convention.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	SparkRel.Implementor	Extension to JavaRelImplementor that can handle Spark relational expressions.
static class	SparkRel.Result	Result of generating Java code to implement a Spark relational expression.

Nested classes/interfaces inherited from interface org.apache.calcite.rel.RelNode

RelNode.Context

Field Summary

Fields

Modifier and Type	Field	Description
static final Convention	CONVENTION	Calling convention for relational operations that occur in Spark.

Method Summary

Modifier and Type	Method	Description
SparkRel.Result	implementSpark(SparkRel.Implementor implementor)

Methods inherited from interface org.apache.calcite.rel.RelNode

accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, copy, deepEquals, deepHashCode, estimateRowCount, explain, explain, fieldIsNullable, getConvention, getCorrelVariable, getDigest, getExpectedInputRowType, getInput, getInputs, getRelDigest, getRelTypeName, getRowType, getTable, getVariablesSet, isEnforcer, isValid, metadata, onRegister, recomputeDigest, register, replaceInput

Methods inherited from interface org.apache.calcite.plan.RelOptNode

getCluster, getDescription, getId, getTraitSet

Field Details

CONVENTION

static final Convention CONVENTION

Calling convention for relational operations that occur in Spark.

Method Details

implementSpark

SparkRel.Result implementSpark(SparkRel.Implementor implementor)