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 b5ca192 [BEAM-9547] Auto-populate any unimplemented
methods/properties with not_implemented_method (#13224)
add 64ec3da [BEAM-10892] Add Proto support to Kafka Table Provider
(#12838)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
.../extensions/protobuf/ProtoMessageSchema.java | 76 ++++++++++++++
.../protobuf/ProtoMessageSchemaTest.java | 21 ++++
.../sdk/extensions/protobuf/TestProtoSchemas.java | 28 +++++
sdks/java/extensions/sql/build.gradle | 14 ++-
.../meta/provider/kafka/BeamKafkaProtoTable.java | 116 +++++++++++++++++++++
.../meta/provider/kafka/KafkaTableProvider.java | 11 +-
.../provider/kafka/BeamKafkaTableAvroTest.java | 4 -
.../provider/kafka/BeamKafkaTableProtoTest.java | 116 +++++++++++++++++++++
.../meta/provider/kafka/BeamKafkaTableTest.java | 4 +-
.../meta/provider/kafka/KafkaTableProviderIT.java | 29 +++---
...rAvroIT.java => KafkaTableProviderProtoIT.java} | 22 +++-
.../provider/kafka/KafkaTableProviderTest.java | 33 +++++-
.../sql/src/test/proto/kafka/kafka_messages.proto} | 33 +++---
.../dsls/sql/extensions/create-external-table.md | 7 +-
15 files changed, 469 insertions(+), 46 deletions(-)
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/BeamKafkaProtoTable.java
create mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/BeamKafkaTableProtoTest.java
copy
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/{KafkaTableProviderAvroIT.java
=> KafkaTableProviderProtoIT.java} (68%)
copy sdks/{go/pkg/beam/io/pubsubio/v1/v1.proto =>
java/extensions/sql/src/test/proto/kafka/kafka_messages.proto} (65%)
