org.apache.calcite.interpreter

Class Nodes.CoreCompiler

java.lang.Object

org.apache.calcite.rel.RelVisitor

org.apache.calcite.interpreter.Nodes.CoreCompiler

All Implemented Interfaces:

Compiler, ReflectiveVisitor

Enclosing class:

Nodes

public static class Nodes.CoreCompiler
extends RelVisitor

Extension to Interpreter.CompilerImpl that knows how to handle the core logical RelNodes.

Field Summary

Fields

Modifier and Type	Field and Description
protected Interpreter	interpreter
protected Node	node
protected RelNode	rel
protected RelNode	rootRel

Method Summary

Modifier and Type	Method and Description
RelDataType	combinedRowType(List<RelNode> inputs)
Scalar	compile(List<RexNode> nodes, RelDataType inputRowType) Compiles an expression to an executable form.
Context	createContext()
void	enumerable(RelNode rel, Enumerable<Row> rowEnumerable) Tells the interpreter that a given relational expression wishes to give its output as an enumerable.
DataContext	getDataContext()
void	rewrite(RelNode r) Fallback rewrite method.
Sink	sink(RelNode rel) Creates a Sink for a relational expression to write into.
Source	source(RelNode rel, int ordinal)
void	visit(Aggregate agg)
void	visit(Bindables.BindableTableScan scan)
void	visit(Filter filter)
void	visit(Join join)
void	visit(Project project)
void	visit(RelNode p, int ordinal, RelNode parent) Visits a node during a traversal.
void	visit(Sort sort)
void	visit(TableScan scan)
void	visit(Union union)
void	visit(Values value)
void	visit(Window window)

Methods inherited from class org.apache.calcite.rel.RelVisitor

go, replaceRoot

Methods inherited from class java.lang.Object

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

Field Detail

interpreter

protected final Interpreter interpreter

rootRel

protected RelNode rootRel

rel

protected RelNode rel

node

protected Node node

Method Detail

visit

public void visit(Aggregate agg)

visit

public void visit(Filter filter)

visit

public void visit(Project project)

visit

public void visit(Values value)

visit

public void visit(TableScan scan)

visit

public void visit(Bindables.BindableTableScan scan)

visit

public void visit(Sort sort)

visit

public void visit(Union union)

visit

public void visit(Join join)

visit

public void visit(Window window)

visit

public void visit(RelNode p,
                  int ordinal,
                  RelNode parent)

Description copied from class: RelVisitor

Visits a node during a traversal.

Overrides:

visit in class RelVisitor

Parameters:

p - Node to visit

ordinal - Ordinal of node within its parent

parent - Parent of the node, or null if it is the root of the traversal

rewrite

public void rewrite(RelNode r)

Fallback rewrite method.

Overriding methods (each with a different sub-class of RelNode as its argument type) sets the rel field if intends to rewrite.

compile

public Scalar compile(List<RexNode> nodes,
                      RelDataType inputRowType)

Description copied from interface: Compiler

Compiles an expression to an executable form.

Specified by:

compile in interface Compiler

combinedRowType

public RelDataType combinedRowType(List<RelNode> inputs)

Specified by:

combinedRowType in interface Compiler

source

public Source source(RelNode rel,
                     int ordinal)

Specified by:

source in interface Compiler

sink

public Sink sink(RelNode rel)

Description copied from interface: Compiler

Creates a Sink for a relational expression to write into.

This method is generally called from the constructor of a Node. But a constructor could instead call Compiler.enumerable(RelNode, Enumerable).

Specified by:

sink in interface Compiler

Parameters:

rel - Relational expression

Returns:

Sink

enumerable

public void enumerable(RelNode rel,
                       Enumerable<Row> rowEnumerable)

Description copied from interface: Compiler

Tells the interpreter that a given relational expression wishes to give its output as an enumerable.

This is as opposed to the norm, where a relational expression calls Compiler.sink(RelNode), then its Node.run() method writes into that sink.

Specified by:

enumerable in interface Compiler

Parameters:

rel - Relational expression

rowEnumerable - Contents of relational expression

createContext

public Context createContext()

Specified by:

createContext in interface Compiler

getDataContext

public DataContext getDataContext()

Specified by:

getDataContext in interface Compiler