...
Page properties |
---|
Current state: "Under Discussion",
Discussion thread: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-64-Support-for-Temporary-Objects-in-Table-module-td32684.html
JIRA:
Released: <Flink Version>
|
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
As a result of the rework of the type system in UDFs, we will be able to merge the three methods into a single one. Moreover for permanent functions we need users to register a class instead of an instance. To keep this method in sync with SQL DDL we should encourage users to use a class name for temporary functions as well.
We use the “create” prefix rather than “register” to be closer to SQL DDL we should encourage users to use a class name for temporary functions as well.
We use the “create” prefix rather than “register” to be closer to SQL DDL.
Suggested methods:
...
.
Suggested methods:
void createTemporaryFunction(String path, Class<? extends UserDefinedFunction> functionClass);
There were concerns raised if we need a variant that registers instances. This FLIP does not make any assumptions if we should or not introduce that method. We will revisit that after FLIP-65
The method to be discussed:
void createTemporaryFunction(String path, UserDefinedFunction function);
ConnectTableDescriptor#registerTableSink,registerTableSource,registerTableSourceAndSink
...