[
https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15943378#comment-15943378
]
ASF GitHub Bot commented on FLINK-6196:
---------------------------------------
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
----
> Support dynamic schema in Table Function
> ----------------------------------------
>
> Key: FLINK-6196
> URL: https://issues.apache.org/jira/browse/FLINK-6196
> Project: Flink
> Issue Type: Improvement
> Reporter: Zhuoluo Yang
> Assignee: Zhuoluo Yang
>
> In many of our use cases. We have to decide the schema of a UDTF at the run
> time. For example. udtf('c1, c2, c3') will generate three columns for a
> lateral view.
> Most systems such as calcite and hive support this feature. However, the
> current implementation of flink didn't implement the feature correctly.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
