flink
flink copied to clipboard
[FLINK-27891][Table] Add ARRAY_APPEND and ARRAY_PREPEND functions
What is the purpose of the change
This is an implementation of ARRAY_APPEND and ARRAY_PREPEND inspired by https://github.com/apache/flink/pull/19543
Brief change log
- ARRAY_APPEND for Table API and SQL
- ARRAY_PREPEND for Table API and SQL
Verifying this change
This change added tests in CollectionFunctionsITCase
Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): ( no)
- The public API, i.e., is any changed class annotated with
@Public(Evolving): (yes ) - The serializers: (no)
- The runtime per-record code paths (performance sensitive): ( no)
- Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: ( no)
- The S3 file system connector: ( no)
Documentation
- Does this pull request introduce a new feature? (yes)
- If yes, how is the feature documented? (docs)
CI report:
- f638db8116a5dc87489e640891366b8c09252f00 Azure: SUCCESS
Bot commands
The @flinkbot bot supports the following commands:@flinkbot run azurere-run the last Azure build
@flinkbot run azure
yes i will
rebased to fix conflicts
rebased since there were several build failure fixes in master
@flinkbot run azure
@snuyanzin thanks for your pr, LGTM
@snuyanzin Are you still working on finalizing this PR?
ah.. sorry completely forgot abou it yeah, I'm going to fix the conflicts and merge after build is green
@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
rebased to resolve conflicts