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 <[email protected]> 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 [email protected].
