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 d576085 [BEAM-8659] RowJsonTest should test serialization
independently
add cf3f12d [BEAM-8743] Add support for flat schemas in pubsub
No new revisions were added by this update.
Summary of changes:
.../meta/provider/pubsub/PubsubIOJsonTable.java | 151 ++++++-------
.../provider/pubsub/PubsubJsonTableProvider.java | 122 +++++++++--
.../meta/provider/pubsub/PubsubMessageToRow.java | 66 ++++--
.../meta/provider/pubsub/RowToPubsubMessage.java | 78 +++++++
.../sdk/extensions/sql/PubsubToBigqueryIT.java | 51 +++++
.../sql/meta/provider/pubsub/PubsubJsonIT.java | 242 ++++++++++++++++++++-
.../pubsub/PubsubJsonTableProviderTest.java | 45 +---
.../provider/pubsub/PubsubMessageToRowTest.java | 109 ++++++++++
8 files changed, 715 insertions(+), 149 deletions(-)
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/RowToPubsubMessage.java
