This is an automated email from the ASF dual-hosted git repository.
amaliujia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 21feb59 Merge pull request #14173: [BEAM-11941] Upgrade Flink runner
to Flink version 1.12.2
add 4e7d645 [BEAM-11659] Allow Kafka sql table provider to have a nested
mode and raw binary payloads (#14016)
No new revisions were added by this update.
Summary of changes:
.../sql/meta/provider/kafka/BeamKafkaCSVTable.java | 37 ++-
.../sql/meta/provider/kafka/BeamKafkaTable.java | 15 +-
.../meta/provider/kafka/KafkaTableProvider.java | 46 ++--
.../provider/kafka/NestedPayloadKafkaTable.java | 181 +++++++++++++
.../kafka/PayloadSerializerKafkaTable.java | 25 +-
.../sql/meta/provider/kafka/Schemas.java | 107 ++++++++
.../provider/kafka/BeamKafkaTableAvroTest.java | 3 +-
.../meta/provider/kafka/BeamKafkaTableCSVTest.java | 2 +-
.../provider/kafka/BeamKafkaTableJsonTest.java | 3 +-
.../provider/kafka/BeamKafkaTableProtoTest.java | 9 +-
.../meta/provider/kafka/BeamKafkaTableTest.java | 42 ++-
.../provider/kafka/BeamKafkaTableThriftTest.java | 9 +-
.../meta/provider/kafka/KafkaTableProviderIT.java | 61 +++++
.../provider/kafka/KafkaTableProviderTest.java | 69 ++++-
.../sql/meta/provider/kafka/KafkaTestTable.java | 9 +-
.../kafka/NestedPayloadKafkaTableTest.java | 290 +++++++++++++++++++++
.../org/apache/beam/sdk/io/kafka/KafkaRecord.java | 4 +-
17 files changed, 843 insertions(+), 69 deletions(-)
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/NestedPayloadKafkaTable.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/Schemas.java
create mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/NestedPayloadKafkaTableTest.java
