Package org.apache.calcite.adapter.spark
Adapter based on the Apache Spark data management system.
-
Interface Summary Interface Description SparkRel Relational expression that uses Spark calling convention. -
Class Summary Class Description EnumerableToSparkConverter Relational expression that converts input ofEnumerableConvention
intoSpark convention
.EnumerableToSparkConverterRule Rule to convert a relational expression fromJdbcConvention
toSpark convention
.HttpServer An HTTP server for static content used to allow worker nodes to access JARs.JdbcToSparkConverter Relational expression representing a scan of a table in a JDBC data source that returns its results as a Spark RDD.JdbcToSparkConverterRule Rule to convert a relational expression fromJdbcConvention
toSpark convention
.SparkHandlerImpl Implementation ofCalcitePrepare.SparkHandler
.SparkRel.Implementor Extension toJavaRelImplementor
that can handle Spark relational expressions.SparkRel.Result Result of generating Java code to implement a Spark relational expression.SparkRules Rules for theSpark calling convention
.SparkRules.EnumerableToSparkConverterRule Planner rule that converts from enumerable to Spark convention.SparkRules.SparkCalc Implementation ofCalc
in Spark convention.SparkRules.SparkCalcRule Rule to convert aLogicalCalc
to anSparkRules.SparkCalc
.SparkRules.SparkToEnumerableConverterRule Planner rule that converts from Spark to enumerable convention.SparkRules.SparkValues VALUES construct implemented in Spark.SparkRules.SparkValuesRule Planner rule that implements VALUES operator in Spark convention.SparkRuntime Runtime utilities for Calcite's Spark adapter.SparkRuntime.CalciteFlatMapFunction<T,R> Combines linq4jFunction
and SparkFlatMapFunction
.SparkToEnumerableConverter Relational expression that converts input ofSpark convention
intoEnumerableConvention
.SparkToEnumerableConverter.SparkImplementorImpl Implementation ofSparkRel.Implementor
. -
Enum Summary Enum Description SparkMethod Built-in methods in the Spark adapter.