beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amaliu...@apache.org
Subject [beam] branch master updated (21feb59 -> 4e7d645)
Date Tue, 09 Mar 2021 18:01:31 GMT
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


Mime
View raw message