beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bhule...@apache.org
Subject [beam] branch master updated (4827bea -> 9de4ea4)
Date Wed, 30 Dec 2020 00:27:50 GMT
This is an automated email from the ASF dual-hosted git repository.

bhulette pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 4827bea  [BEAM-11537] Fix TestPubSubSignal.waitForStart (#13632)
     add 9de4ea4  [BEAM-11482] Thrift support for KafkaTableProvider (#13572)

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         |   1 +
 .../src/main/resources/beam/suppressions.xml       |   1 +
 .../org/apache/beam/sdk/schemas/RowMessages.java   | 132 +++
 .../extensions/protobuf/ProtoMessageSchema.java    |  68 +-
 sdks/java/extensions/sql/build.gradle              |   2 +
 .../meta/provider/kafka/BeamKafkaThriftTable.java  | 138 ++++
 .../meta/provider/kafka/KafkaTableProvider.java    |  56 +-
 ...rotoTest.java => BeamKafkaTableThriftTest.java} |  53 +-
 .../meta/provider/kafka/KafkaTableProviderIT.java  |  47 +-
 .../provider/kafka/KafkaTableProviderTest.java     |  55 +-
 .../provider/kafka/thrift/ItThriftMessage.java     | 612 ++++++++++++++
 .../kafka/thrift/SimpleThriftMessage.java}         | 341 ++++----
 .../provider/kafka/thrift/TestThriftMessage.java   | 881 +++++++++++++++++++++
 .../src/test/thrift/kafka/messages.thrift}         |  45 +-
 .../org/apache/beam/sdk/io/thrift/ThriftCoder.java |   5 +-
 .../apache/beam/sdk/io/thrift/ThriftSchema.java    |  92 ++-
 .../dsls/sql/extensions/create-external-table.md   |  11 +-
 17 files changed, 2204 insertions(+), 336 deletions(-)
 create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/RowMessages.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/BeamKafkaThriftTable.java
 copy sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/{BeamKafkaTableProtoTest.java
=> BeamKafkaTableThriftTest.java} (63%)
 create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/thrift/ItThriftMessage.java
 copy sdks/java/{io/thrift/src/test/java/org/apache/beam/sdk/io/thrift/TestThriftInnerStruct.java
=> extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/thrift/SimpleThriftMessage.java}
(55%)
 create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/thrift/TestThriftMessage.java
 copy sdks/java/extensions/{protobuf/src/test/proto/proto2_coder_test_messages.proto =>
sql/src/test/thrift/kafka/messages.thrift} (55%)


Mime
View raw message