GitHub user clarkyzl opened a pull request:
https://github.com/apache/flink/pull/3529
[FLINK-6039] [core] Row of TableFunction should support flexible number of
fields
Type: Improvement
Priority: Major
Components: core, table, udtf
Problem Definition: Row of TableFunction should support flexible number of
fields. The number of fields should not be fixed. The framework should allow
the scenario that the field numbers of the `Row`s are different from the
`TypeInformation` number of the `ResultType`s.
Design:
It would throw a IndexOutOfBoundException when accessing the position
larger than or equal to the number of fields in a Row, before the patch. It
will return null after the patch.
Impact Analysis:
The behavior of the Row#getField has changed.
Test:
`mvn clean verify` is done.
The case `TableFunc4` and `TableFunc6` would pass no matter this patch is
patched or not. They are here to make sure the case works.
The case `TableFunc5` would success after the patch is patched.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/clarkyzl/flink flink-6039
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3529.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 #3529
----
commit 9814ec01ed0f8031f055bea63e01d713f56945a2
Author: Zhuoluo Yang <[email protected]>
Date: 2017-03-14T08:44:02Z
[FLINK-6039] [core] Row of TableFunction should support flexible number of
fields
----
---
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.
---
