GitHub user clarkyzl opened a pull request:
https://github.com/apache/flink/pull/3623
[FLINK-6196] [table] Support dynamic schema in Table Function
Type: Improvement
Priority: Major
Components: table, udtf
Problem Definition: Support dynamic schema in Table Function
Design:
1. Modified the getResult() interfaces of an UDTF. Suport java sytle
arguments of a list. only literals will be passed to the UDTf.
1. Define the TableFunction and TableFunctionCall clearly. A TableFunction
is an object that the ResultType and parameters are not determined. A
TableFunctionCall is an object that thre ResultType and paramenters are
determined.
1. Implement the TableAPI, Expression and SQL style call stack of the
getResultType.
Impact Analysis:
UDTF, an interface has changed.
Test:
All tests done.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/clarkyzl/flink flink-6196
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3623.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3623
----
commit 9be655dec415a720051b85ae78e7f052a6e22f81
Author: Zhuoluo Yang <[email protected]>
Date: 2017-03-14T08:44:02Z
[FLINK-6039] [core] Row of TableFunction should support flexible number of
fields
commit a87721b18a6972cd0b80384a0812df27b5253f9c
Author: Zhuoluo Yang <[email protected]>
Date: 2017-03-16T06:34:39Z
[FLINK-6039] [core] Revert some modifications
commit 140e6c76b51a80b35c1071590b19aefbf65990eb
Author: Zhuoluo Yang <[email protected]>
Date: 2017-03-17T16:56:13Z
[FLINK-6039] [core] Support dynamic schema of TableFunction
commit 6ac05e217acb6c0c73a1ea978891ff88d78bc0a8
Author: Zhuoluo Yang <[email protected]>
Date: 2017-03-22T03:49:49Z
[FLINK-6039] [core] Fix the dynamic schema of Table API
commit 1c88362c714c7f4e6f0a56397e9cf2801abfcf0a
Author: Zhuoluo Yang <[email protected]>
Date: 2017-03-22T08:29:31Z
[FLINK-6039] [core] Fix build exception
commit eba7ba8cbd7c576510e649f1b4ecad2a55300f82
Author: Zhuoluo Yang <[email protected]>
Date: 2017-03-22T09:53:28Z
[FLINK-6039] [core] fix comments and test failure
commit 768d03d09267ce46b789cf58add9f49455d01585
Author: Zhuoluo Yang <[email protected]>
Date: 2017-03-23T06:00:13Z
Add a test case for the test
commit 6fe805f3b1f83c66c02dca8c65892b7b8d48f3e4
Author: Zhuoluo Yang <[email protected]>
Date: 2017-03-27T14:25:36Z
[FLINK-6196] [table] Support dynamic schema in Table Function
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
