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 8b9e015 [BEAM-9615] Add schema coders and tests. #13209
add b26b499 [BEAM-5504] Add Avro support to Pubsub table provider (#12780)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
.../datacatalog/DataCatalogTableProvider.java | 4 +-
...TableProvider.java => PubsubTableProvider.java} | 4 +-
.../sdk/extensions/sql/PubsubToBigqueryIT.java | 8 +-
.../sql/meta/provider/pubsub/PubsubAvroIT.java | 102 ++++
.../sql/meta/provider/pubsub/PubsubJsonIT.java | 628 +--------------------
...ubsubJsonIT.java => PubsubTableProviderIT.java} | 470 +++++++--------
...viderTest.java => PubsubTableProviderTest.java} | 14 +-
.../beam/sdk/io/gcp/pubsub/PubsubMessageToRow.java | 136 +++--
.../sdk/io/gcp/pubsub/PubsubSchemaIOProvider.java | 23 +-
.../beam/sdk/io/gcp/pubsub/RowToPubsubMessage.java | 79 ++-
.../sdk/io/gcp/pubsub/PubsubMessageToRowTest.java | 28 +-
.../dsls/sql/extensions/create-external-table.md | 29 +-
13 files changed, 577 insertions(+), 949 deletions(-)
rename
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/{PubsubJsonTableProvider.java
=> PubsubTableProvider.java} (91%)
create mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/PubsubAvroIT.java
copy
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/{PubsubJsonIT.java
=> PubsubTableProviderIT.java} (60%)
rename
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/{PubsubJsonTableProviderTest.java
=> PubsubTableProviderTest.java} (89%)
