New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[FLINK-27891][Table] Add ARRAY_APPEND and ARRAY_PREPEND functions #19873
Conversation
@flinkbot run azure |
2e65622
to
f64c3ce
Compare
a218b77
to
7ee5c01
Compare
Arrays.asList( | ||
ARRAY_ELEMENT_ARG1, logical(LogicalTypeRoot.ARRAY)))) | ||
.outputTypeStrategy(nullableIfArgs(argument(1))) | ||
.runtimeClass( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
.outputTypeStrategy(nullableIfArgs(argument(1))) is not correct
...-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java
Show resolved
Hide resolved
yes i will |
rebased to fix conflicts |
0380508
to
2478dac
Compare
...n/java/org/apache/flink/table/types/inference/strategies/ArrayAppendPrependTypeStrategy.java
Show resolved
Hide resolved
rebased since there were several build failure fixes in master |
d60012b
to
09580aa
Compare
@flinkbot run azure |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
@snuyanzin thanks for your pr, LGTM |
@snuyanzin Are you still working on finalizing this PR? |
ah.. sorry completely forgot abou it |
@MartijnVisser since there is a feature freeze do you think it makes sense to add it in 1.19? Otherwise I'm going to add it when a new release starts |
Let's add it for 1.20, and honor the feature freeze |
ac09e6d
to
a7cb97e
Compare
rebased to resolve conflicts |
7fb37ff
to
33f3d2d
Compare
33f3d2d
to
f638db8
Compare
What is the purpose of the change
This is an implementation of
ARRAY_APPEND
andARRAY_PREPEND
inspired by #19543Brief change log
Verifying this change
This change added tests in
CollectionFunctionsITCase
Does this pull request potentially affect one of the following parts:
@Public(Evolving)
: (yes )Documentation