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/30 21:24:27 UTC
[beam] 01/01: Merge pull request #5497: [BEAM-4082] Migrate from
builders in RowSqlTypes to just using Schema builder directly
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 5a1b4ddca6c261cbf871cf68d39d2ea1d668b349
Merge: b414da9 8e3863c
Author: Kenn Knowles <ke...@kennknowles.com>
AuthorDate: Wed May 30 14:24:08 2018 -0700
Merge pull request #5497: [BEAM-4082] Migrate from builders in RowSqlTypes to just using Schema builder directly
.../java/org/apache/beam/sdk/schemas/Schema.java | 10 ++
.../org/apache/beam/sdk/coders/RowCoderTest.java | 3 +-
.../beam/sdk/util/RowJsonDeserializerTest.java | 4 +-
.../beam/sdk/extensions/sql/RowSqlTypes.java | 178 ---------------------
.../sdk/extensions/sql/example/BeamSqlExample.java | 7 +-
.../extensions/sql/impl/utils/CalciteUtils.java | 29 +++-
.../provider/pubsub/PubsubJsonTableProvider.java | 4 +-
.../meta/provider/pubsub/PubsubMessageToRow.java | 3 +-
.../beam/sdk/extensions/sql/BeamSqlCliTest.java | 19 +--
.../sql/BeamSqlDslAggregationCovarianceTest.java | 14 +-
.../extensions/sql/BeamSqlDslAggregationTest.java | 120 +++++++-------
.../sql/BeamSqlDslAggregationVarianceTest.java | 8 +-
.../sdk/extensions/sql/BeamSqlDslArrayTest.java | 62 +++----
.../beam/sdk/extensions/sql/BeamSqlDslBase.java | 22 +--
.../sdk/extensions/sql/BeamSqlDslJoinTest.java | 32 ++--
.../extensions/sql/BeamSqlDslNestedRowsTest.java | 91 +++++------
.../sdk/extensions/sql/BeamSqlDslProjectTest.java | 11 +-
.../sdk/extensions/sql/BeamSqlDslUdfUdafTest.java | 14 +-
.../beam/sdk/extensions/sql/BeamSqlMapTest.java | 23 +--
.../operator/BeamSqlDotExpressionTest.java | 7 +-
.../row/BeamSqlFieldAccessExpressionTest.java | 9 +-
.../sql/impl/parser/BeamDDLNestedTypesTest.java | 3 +-
.../extensions/sql/impl/parser/BeamDDLTest.java | 4 +-
.../transform/BeamAggregationTransformTest.java | 117 +++++++-------
.../schema/transform/BeamTransformBaseTest.java | 21 ++-
...BeamSqlBuiltinFunctionsIntegrationTestBase.java | 27 ++--
.../BeamSqlComparisonOperatorsIntegrationTest.java | 55 ++++---
.../bigquery/BigQueryTableProviderTest.java | 5 +-
.../provider/kafka/KafkaTableProviderTest.java | 5 +-
.../sql/meta/provider/pubsub/PubsubJsonIT.java | 3 +-
.../pubsub/PubsubJsonTableProviderTest.java | 39 +++--
.../provider/pubsub/PubsubMessageToRowTest.java | 25 ++-
.../meta/provider/text/BeamTextCSVTableTest.java | 13 +-
.../meta/provider/text/TextTableProviderTest.java | 5 +-
.../sql/meta/store/InMemoryMetaStoreTest.java | 10 +-
.../sdk/io/gcp/bigquery/BigQueryUtilsTest.java | 12 +-
.../model/sql/adapter/ModelAdaptersMapping.java | 78 ++++-----
.../beam/sdk/nexmark/queries/sql/SqlQuery3.java | 12 +-
.../beam/sdk/nexmark/model/sql/RowSizeTest.java | 30 ++--
.../sql/adapter/ModelAdaptersMappingTest.java | 53 +++---
40 files changed, 503 insertions(+), 684 deletions(-)
--
To stop receiving notification emails like this one, please contact
kenn@apache.org.