You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2018/05/11 04:00:15 UTC
[beam] 01/01: Merge pull request #5253: [BEAM-4162][SQL] Wire up
PubsubIO to SQL
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit a350152c298fc82b58ccdac91539ba9cc6931038
Merge: 67878d2 0227e91
Author: Kenn Knowles <ke...@kennknowles.com>
AuthorDate: Thu May 10 21:00:08 2018 -0700
Merge pull request #5253: [BEAM-4162][SQL] Wire up PubsubIO to SQL
.../java/org/apache/beam/sdk/schemas/Schema.java | 7 +
.../org/apache/beam/sdk/transforms/JsonToRow.java | 25 +---
.../org/apache/beam/sdk/util/JsonToRowUtils.java | 49 +++++++
sdks/java/extensions/sql/build.gradle | 1 +
sdks/java/extensions/sql/pom.xml | 6 +
.../apache/beam/sdk/extensions/sql/meta/Table.java | 2 +
.../meta/provider/pubsub/PubsubIOJsonTable.java | 157 +++++++++++++++++++++
.../provider/pubsub/PubsubJsonTableProvider.java | 88 ++++++++++++
.../meta/provider/pubsub/PubsubMessageToRow.java | 129 +++++++++++++++++
.../sql/meta/provider/pubsub/package-info.java | 26 ++++
.../sdk/extensions/sql/BeamSqlCliPubsubTest.java | 54 +++++++
.../pubsub/PubsubJsonTableProviderTest.java | 142 +++++++++++++++++++
.../provider/pubsub/PubsubMessageToRowTest.java | 115 +++++++++++++++
13 files changed, 780 insertions(+), 21 deletions(-)
--
To stop receiving notification emails like this one, please contact
kenn@apache.org.