[FLINK-10379] Can not use Table Functions in Java Table API

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.6.1
• Fix Version/s: 1.6.2, 1.7.0
• Component/s: Table API & SQL
• Labels: pull-request-available
• Assignee: Hequn Cheng
• Reporter: Piotr Nowojski
• Created: 20/Sep/18 14:33
• Updated: 17/Oct/18 08:47
• Resolved: 10/Oct/18 11:20

Description

As stated in the [documentation|https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/udfs.html#table-functions,] this is how table functions should be used in Java Table API:

// Register the function.
tableEnv.registerFunction("split", new Split("#"));

myTable.join("split(a) as (word, length)");

However Table.join(String) was removed sometime ago and now it is impossible to use Table Functions in Java Table API.

Issue Links

• is related to: FLINK-9712 Support enrichment joins in Flink SQL/Table API
• links to: GitHub Pull Request #6744