Package | Description |
---|---|
org.apache.flink.table.functions.utils | |
org.apache.flink.table.plan.nodes |
Modifier and Type | Method and Description |
---|---|
static TableSqlFunction |
TableSqlFunction.apply(String name,
TableFunction<?> udtf,
TypeInformation<?> rowTypeInfo,
FlinkTypeFactory typeFactory,
FlinkTableFunctionImpl<?> functionImpl)
Util function to create a
TableSqlFunction . |
TableSqlFunction |
TableSqlFunction$.apply(String name,
TableFunction<?> udtf,
TypeInformation<?> rowTypeInfo,
FlinkTypeFactory typeFactory,
FlinkTableFunctionImpl<?> functionImpl)
Util function to create a
TableSqlFunction . |
Modifier and Type | Method and Description |
---|---|
String |
CommonCorrelate.correlateOpName(org.apache.calcite.rex.RexCall rexCall,
TableSqlFunction sqlFunction,
org.apache.calcite.rel.type.RelDataType rowType) |
String |
CommonCorrelate.correlateToString(org.apache.calcite.rex.RexCall rexCall,
TableSqlFunction sqlFunction) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.