org.apache.flink.api.table.codegen

Class ExpressionCodeGenerator<R>

java.lang.Object

org.apache.flink.api.table.codegen.ExpressionCodeGenerator<R>

Direct Known Subclasses:

GenerateFilter, GenerateResultAssembler

public abstract class ExpressionCodeGenerator<R>
extends Object

Base class for all code generation classes. This provides the functionality for generating code from an Expression tree. Derived classes must embed this in a lambda function to form an executable code block.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ExpressionCodeGenerator.FieldAccessor
class	ExpressionCodeGenerator.GeneratedExpression
class	ExpressionCodeGenerator.ObjectFieldAccessor
class	ExpressionCodeGenerator.ObjectMethodAccessor
class	ExpressionCodeGenerator.ProductAccessor

Constructor Summary

Constructors

Constructor and Description
ExpressionCodeGenerator(scala.collection.Seq<scala.Tuple2<String,CompositeType<?>>> inputs, ClassLoader cl, TableConfig config)

Method Summary

Modifier and Type	Method and Description
void	addDateFormatter()
void	addTimeFormatter()
void	addTimestampFormatter()
org.codehaus.janino.SimpleCompiler	compiler()
protected String	defaultPrimitive(TypeInformation<?> tpe)
org.apache.flink.api.table.codegen.ExpressionCodeGenerator.FieldAccessor	fieldAccessorFor(CompositeType<?> elementType, String fieldName)
String	freshName(String name)
AtomicInteger	freshNameCounter()
R	generate()
protected ExpressionCodeGenerator.GeneratedExpression	generateExpression(Expression expr)
protected ExpressionCodeGenerator.GeneratedExpression	generateExpressionInternal(Expression expr)
protected abstract R	generateInternal()
protected String	getField(scala.reflect.runtime.universe inputTerm, CompositeType<?> inputType, String fieldName, TypeInformation<?> fieldType)
protected org.slf4j.Logger	log()
protected boolean	nullCheck()
protected scala.collection.mutable.Set<String>	reusableInitStatements()
protected scala.collection.mutable.Set<String>	reusableMemberStatements()
protected String	reuseInitCode()
protected String	reuseMemberCode()
protected String	typeTermForTypeInfo(TypeInformation<?> tpe)
protected String	typeTermForTypeInfoForCast(TypeInformation<?> tpe)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExpressionCodeGenerator

public ExpressionCodeGenerator(scala.collection.Seq<scala.Tuple2<String,CompositeType<?>>> inputs,
                               ClassLoader cl,
                               TableConfig config)

Method Detail

log

protected org.slf4j.Logger log()

compiler

public org.codehaus.janino.SimpleCompiler compiler()

reusableMemberStatements

protected scala.collection.mutable.Set<String> reusableMemberStatements()

reusableInitStatements

protected scala.collection.mutable.Set<String> reusableInitStatements()

reuseMemberCode

protected String reuseMemberCode()

reuseInitCode

protected String reuseInitCode()

nullCheck

protected boolean nullCheck()

generateInternal

protected abstract R generateInternal()

generate

public final R generate()

generateExpression

protected ExpressionCodeGenerator.GeneratedExpression generateExpression(Expression expr)

generateExpressionInternal

protected ExpressionCodeGenerator.GeneratedExpression generateExpressionInternal(Expression expr)

freshName

public String freshName(String name)

freshNameCounter

public AtomicInteger freshNameCounter()

getField

protected String getField(scala.reflect.runtime.universe inputTerm,
                          CompositeType<?> inputType,
                          String fieldName,
                          TypeInformation<?> fieldType)

fieldAccessorFor

public org.apache.flink.api.table.codegen.ExpressionCodeGenerator.FieldAccessor fieldAccessorFor(CompositeType<?> elementType,
                                                                                                 String fieldName)

defaultPrimitive

protected String defaultPrimitive(TypeInformation<?> tpe)

typeTermForTypeInfo

protected String typeTermForTypeInfo(TypeInformation<?> tpe)

typeTermForTypeInfoForCast

protected String typeTermForTypeInfoForCast(TypeInformation<?> tpe)

addDateFormatter

public void addDateFormatter()

addTimeFormatter

public void addTimeFormatter()

addTimestampFormatter

public void addTimestampFormatter()