You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bh...@apache.org on 2020/10/29 20:24:12 UTC
[beam] branch master updated (8b9e015 -> b26b499)
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%)