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 java.lang.Object implements CalcitePrepare.SparkHandler
Implementation ofCalcitePrepare.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
-
-
Field Summary
Fields Modifier and Type Field Description private static java.io.File
CLASS_DIR
private java.util.concurrent.atomic.AtomicInteger
classId
private HttpServer
classServer
private static SparkHandlerImpl
instance
private org.apache.spark.api.java.JavaSparkContext
sparkContext
-
Constructor Summary
Constructors Modifier Constructor Description private
SparkHandlerImpl()
Creates a SparkHandlerImpl.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description ArrayBindable
compile(ClassDeclaration expr, java.lang.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)
java.lang.Object
sparkContext()
-
-
-
Field Detail
-
classServer
private final HttpServer classServer
-
classId
private final java.util.concurrent.atomic.AtomicInteger classId
-
sparkContext
private final org.apache.spark.api.java.JavaSparkContext sparkContext
-
instance
private static SparkHandlerImpl instance
-
CLASS_DIR
private static final java.io.File CLASS_DIR
-
-
Method Detail
-
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 interfaceCalcitePrepare.SparkHandler
-
registerRules
public void registerRules(CalcitePrepare.SparkHandler.RuleSetBuilder builder)
- Specified by:
registerRules
in interfaceCalcitePrepare.SparkHandler
-
sparkContext
public java.lang.Object sparkContext()
- Specified by:
sparkContext
in interfaceCalcitePrepare.SparkHandler
-
enabled
public boolean enabled()
- Specified by:
enabled
in interfaceCalcitePrepare.SparkHandler
-
compile
public ArrayBindable compile(ClassDeclaration expr, java.lang.String s)
- Specified by:
compile
in interfaceCalcitePrepare.SparkHandler
-
-