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%)
|