Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.codegen | |
org.apache.flink.table.plan.nodes | |
org.apache.flink.table.plan.nodes.logical |
Modifier and Type | Method and Description |
---|---|
protected <OUT> GeneratedFunction<MapFunction<Row,OUT>,OUT> |
TableEnvironment.generateRowConverterFunction(TypeInformation<Row> inputTypeInfo,
RowSchema schema,
TypeInformation<OUT> requestedTypeInfo,
String functionName) |
Modifier and Type | Method and Description |
---|---|
<F extends Function,T> |
CodeGenerator.generateFunction(String name,
Class<F> clazz,
String bodyCode,
TypeInformation<T> returnType)
Generates a
Function that can be passed to Java
compiler. |
Modifier and Type | Method and Description |
---|---|
<F extends Function> |
CommonScan.generatedConversionFunction(TableConfig config,
Class<F> functionClass,
TypeInformation<Object> inputType,
TypeInformation<Row> expectedType,
String conversionOperatorName,
scala.collection.Seq<String> fieldNames,
scala.Option<int[]> inputFieldMapping) |
<T extends Function> |
CommonCalc.generateFunction(CodeGenerator generator,
String ruleDescription,
RowSchema inputSchema,
RowSchema returnSchema,
org.apache.calcite.rex.RexProgram calcProgram,
TableConfig config,
Class<T> functionClass) |
<T extends Function> |
CommonCorrelate.generateFunction(TableConfig config,
RowSchema inputSchema,
TypeInformation<Object> udtfTypeInfo,
RowSchema returnSchema,
org.apache.calcite.sql.SemiJoinType joinType,
org.apache.calcite.rex.RexCall rexCall,
scala.Option<int[]> pojoFieldMapping,
String ruleDescription,
Class<T> functionClass)
Generates the flat map function to run the user-defined table function.
|
Modifier and Type | Method and Description |
---|---|
static <T extends Function> |
FlinkLogicalCalc.generateFunction(CodeGenerator generator,
String ruleDescription,
RowSchema inputSchema,
RowSchema returnSchema,
org.apache.calcite.rex.RexProgram calcProgram,
TableConfig config,
Class<T> functionClass) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.