Package org.apache.calcite.adapter.spark

Class SparkRel.Implementor

java.lang.Object

org.apache.calcite.adapter.enumerable.JavaRelImplementor

org.apache.calcite.adapter.spark.SparkRel.Implementor

All Implemented Interfaces:

RelImplementor

Direct Known Subclasses:

SparkToEnumerableConverter.SparkImplementorImpl

Enclosing interface:

SparkRel

public abstract static class SparkRel.Implementor
extends JavaRelImplementor

Extension to JavaRelImplementor that can handle Spark relational expressions.

Constructor Summary

Constructors

Constructor	Description
Implementor(RexBuilder rexBuilder)

Method Summary

Modifier and Type	Method	Description
(package private) abstract SparkRel.Result	result(PhysType physType, BlockStatement blockStatement)
(package private) abstract SparkRel.Result	visitInput(SparkRel parent, int ordinal, SparkRel input)

Methods inherited from class org.apache.calcite.adapter.enumerable.JavaRelImplementor

getRexBuilder, getRootExpression, getTypeFactory

Methods inherited from class java.lang.Object

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

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

getConformance

Constructor Detail

Implementor

public Implementor(RexBuilder rexBuilder)

Method Detail

result

abstract SparkRel.Result result(PhysType physType,
                                BlockStatement blockStatement)

visitInput

abstract SparkRel.Result visitInput(SparkRel parent,
                                    int ordinal,
                                    SparkRel input)