This is an automated email from the ASF dual-hosted git repository.
raminqaf pushed a change to branch release-2.4
in repository https://gitbox.apache.org/repos/asf/flink.git
from a065f5beb87 [FLINK-41202][docs] Make connector integrations easier to
find from the Flink docs (#29609)
new 49c0e9ab9b2 [FLINK-41243][table] Support VARIANT field access with a
non-literal key
new 16e07dcf577 [FLINK-41241][core] Add VariantFieldGetter to read an
object field by a fixed key
new 85d807e130f [FLINK-41241][table] Use VariantFieldGetter for v['key']
and CAST to ROW
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/flink/types/variant/BinaryVariant.java | 104 +++++++++++++++------
.../flink/types/variant/BinaryVariantUtil.java | 48 +++++++---
.../flink/types/variant/VariantFieldGetter.java | 63 +++++++++++++
.../flink/types/variant/BinaryVariantTest.java | 25 +++++
.../table/data/utils/FromVariantConverter.java | 5 +-
.../planner/codegen/calls/ScalarOperatorGens.scala | 20 ++--
.../nodes/exec/stream/VariantSemanticTest.java | 89 ++++++++++++++++++
7 files changed, 306 insertions(+), 48 deletions(-)
create mode 100644
flink-core/src/main/java/org/apache/flink/types/variant/VariantFieldGetter.java
