public class TableSqlFunction$ extends Object
Modifier and Type | Field and Description |
---|---|
static TableSqlFunction$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
TableSqlFunction$() |
Modifier and Type | Method and Description |
---|---|
TableSqlFunction |
apply(String name,
TableFunction<?> udtf,
TypeInformation<?> rowTypeInfo,
FlinkTypeFactory typeFactory,
FlinkTableFunctionImpl<?> functionImpl)
Util function to create a
TableSqlFunction . |
public static final TableSqlFunction$ MODULE$
public TableSqlFunction apply(String name, TableFunction<?> udtf, TypeInformation<?> rowTypeInfo, FlinkTypeFactory typeFactory, FlinkTableFunctionImpl<?> functionImpl)
TableSqlFunction
.
name
- function name (used by SQL parser)udtf
- user-defined table function to be calledrowTypeInfo
- the row type information generated by the table functiontypeFactory
- type factory for converting Flink's between Calcite's typesfunctionImpl
- Calcite table function schemaTableSqlFunction
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.