Package org.apache.calcite.adapter.spark

Class SparkHandlerImpl

java.lang.Object

org.apache.calcite.adapter.spark.SparkHandlerImpl

All Implemented Interfaces:

CalcitePrepare.SparkHandler

public class SparkHandlerImpl
extends Object
implements CalcitePrepare.SparkHandler

Implementation of CalcitePrepare.SparkHandler. Gives the core Calcite engine access to rules that only exist in the Spark module.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.jdbc.CalcitePrepare.SparkHandler

CalcitePrepare.SparkHandler.RuleSetBuilder

Method Summary

Modifier and Type	Method	Description
ArrayBindable	compile(ClassDeclaration expr, String s)
boolean	enabled()
RelNode	flattenTypes(RelOptPlanner planner, RelNode rootRel, boolean restructure)
static CalcitePrepare.SparkHandler	instance()	Creates a SparkHandlerImpl, initializing on first call.
void	registerRules(CalcitePrepare.SparkHandler.RuleSetBuilder builder)
Object	sparkContext()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

instance

public static CalcitePrepare.SparkHandler instance()

Creates a SparkHandlerImpl, initializing on first call. Calcite-core calls this via reflection.

flattenTypes

public RelNode flattenTypes(RelOptPlanner planner,
 RelNode rootRel,
 boolean restructure)

Specified by:

flattenTypes in interface CalcitePrepare.SparkHandler

registerRules

public void registerRules(CalcitePrepare.SparkHandler.RuleSetBuilder builder)

Specified by:

registerRules in interface CalcitePrepare.SparkHandler

sparkContext

public Object sparkContext()

Specified by:

sparkContext in interface CalcitePrepare.SparkHandler

enabled

public boolean enabled()

Specified by:

enabled in interface CalcitePrepare.SparkHandler

compile

public ArrayBindable compile(ClassDeclaration expr,
 String s)

Specified by:

compile in interface CalcitePrepare.SparkHandler