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 06a4a15cf565cae247782da2d2a5483a00ae8f3c
Merge: 92fd354 1419f56
Author: Kenn Knowles <k...@kennknowles.com>
AuthorDate: Tue Feb 6 16:00:41 2018 -0800
Merge pull request #4593: [BEAM-2721] Refactor BeamRecordType and BeamRecord
.../apache/beam/sdk/coders/BeamRecordCoder.java | 10 +-
.../org/apache/beam/sdk/values/BeamRecord.java | 188 ++++++++++----------
.../org/apache/beam/sdk/values/BeamRecordType.java | 123 ++++++++------
.../org/apache/beam/sdk/values/BeamRecordTest.java | 113 ++++++++++++
.../apache/beam/sdk/values/BeamRecordTypeTest.java | 85 +++++++++
.../beam/sdk/extensions/sql/BeamRecordSqlType.java | 14 +-
.../sdk/extensions/sql/example/BeamSqlExample.java | 10 +-
.../operator/BeamSqlInputRefExpression.java | 2 +-
.../sql/impl/rel/BeamAggregationRel.java | 40 ++---
.../sdk/extensions/sql/impl/rel/BeamJoinRel.java | 20 ++-
.../sdk/extensions/sql/impl/rel/BeamSortRel.java | 10 +-
.../sdk/extensions/sql/impl/rel/BeamValuesRel.java | 43 +++--
.../extensions/sql/impl/schema/BeamTableUtils.java | 22 +--
.../impl/transform/BeamAggregationTransforms.java | 66 +++----
.../sql/impl/transform/BeamJoinTransforms.java | 97 ++++++-----
.../impl/transform/BeamSqlOutputToConsoleFn.java | 2 +-
.../sql/impl/transform/BeamSqlProjectFn.java | 34 ++--
.../extensions/sql/impl/utils/CalciteUtils.java | 27 +--
.../extensions/sql/meta/provider/MetaUtils.java | 17 +-
.../extensions/sql/BeamSqlDslAggregationTest.java | 125 ++++++++++----
.../sdk/extensions/sql/BeamSqlDslProjectTest.java | 59 ++++---
.../sdk/extensions/sql/BeamSqlDslUdfUdafTest.java | 4 +-
.../apache/beam/sdk/extensions/sql/TestUtils.java | 36 ++--
.../interpreter/BeamSqlFnExecutorTestBase.java | 27 +--
.../rel/BeamJoinRelUnboundedVsBoundedTest.java | 3 +-
.../sql/impl/schema/BeamSqlRowCoderTest.java | 55 +++---
.../transform/BeamAggregationTransformTest.java | 189 ++++++++++++---------
.../schema/transform/BeamTransformBaseTest.java | 161 +++++++-----------
...BeamSqlBuiltinFunctionsIntegrationTestBase.java | 23 +--
.../meta/provider/kafka/BeamKafkaCSVTableTest.java | 40 ++---
.../meta/provider/text/BeamTextCSVTableTest.java | 68 +++-----
.../beam/sdk/nexmark/model/sql/BeamRecordSize.java | 2 +-
.../beam/sdk/nexmark/model/sql/ToBeamRecord.java | 5 +-
.../sdk/nexmark/model/sql/BeamRecordSizeTest.java | 40 ++---
.../sdk/nexmark/model/sql/ToBeamRecordTest.java | 27 +--
.../sdk/nexmark/queries/sql/SqlQuery0Test.java | 10 +-
.../sdk/nexmark/queries/sql/SqlQuery1Test.java | 10 +-
.../sdk/nexmark/queries/sql/SqlQuery2Test.java | 7 +-
.../sdk/nexmark/queries/sql/SqlQuery3Test.java | 15 +-
39 files changed, 1093 insertions(+), 736 deletions(-)
--
To stop receiving notification emails like this one, please contact
k...@apache.org.
