You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ta...@apache.org on 2017/08/09 16:41:01 UTC
[3/3] beam git commit: [BEAM-2745] This closes #3700
[BEAM-2745] This closes #3700
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f59dccc5
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f59dccc5
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f59dccc5
Branch: refs/heads/DSL_SQL
Commit: f59dccc51abc8326bea3918766c62add93306fda
Parents: 6628674 7c76129
Author: Tyler Akidau <ta...@apache.org>
Authored: Wed Aug 9 09:38:45 2017 -0700
Committer: Tyler Akidau <ta...@apache.org>
Committed: Wed Aug 9 09:38:45 2017 -0700
----------------------------------------------------------------------
.../org/apache/beam/sdk/values/BeamRecord.java | 21 ++-
.../apache/beam/sdk/values/BeamRecordType.java | 25 +--
.../apache/beam/sdk/extensions/sql/BeamSql.java | 4 +-
.../beam/sdk/extensions/sql/BeamSqlEnv.java | 6 +-
.../extensions/sql/example/BeamSqlExample.java | 4 +-
.../sql/impl/rel/BeamAggregationRel.java | 16 +-
.../extensions/sql/impl/rel/BeamJoinRel.java | 10 +-
.../extensions/sql/impl/rel/BeamValuesRel.java | 6 +-
.../transform/BeamAggregationTransforms.java | 25 +--
.../sql/impl/transform/BeamJoinTransforms.java | 22 +--
.../sql/impl/transform/BeamSqlProjectFn.java | 8 +-
.../extensions/sql/impl/utils/CalciteUtils.java | 16 +-
.../extensions/sql/schema/BaseBeamTable.java | 6 +-
.../sql/schema/BeamPCollectionTable.java | 4 +-
.../sql/schema/BeamRecordSqlType.java | 185 +++++++++++++++++++
.../sql/schema/BeamSqlRecordHelper.java | 4 +-
.../sql/schema/BeamSqlRecordType.java | 175 ------------------
.../sdk/extensions/sql/schema/BeamSqlTable.java | 2 +-
.../extensions/sql/schema/BeamTableUtils.java | 14 +-
.../sql/schema/kafka/BeamKafkaCSVTable.java | 14 +-
.../sql/schema/kafka/BeamKafkaTable.java | 6 +-
.../sql/schema/text/BeamTextCSVTable.java | 6 +-
.../schema/text/BeamTextCSVTableIOReader.java | 6 +-
.../schema/text/BeamTextCSVTableIOWriter.java | 6 +-
.../sql/schema/text/BeamTextTable.java | 4 +-
.../sql/BeamSqlDslAggregationTest.java | 14 +-
.../beam/sdk/extensions/sql/BeamSqlDslBase.java | 6 +-
.../sdk/extensions/sql/BeamSqlDslJoinTest.java | 10 +-
.../extensions/sql/BeamSqlDslProjectTest.java | 10 +-
.../extensions/sql/BeamSqlDslUdfUdafTest.java | 6 +-
.../beam/sdk/extensions/sql/TestUtils.java | 14 +-
.../interpreter/BeamSqlFnExecutorTestBase.java | 4 +-
...mSqlBuiltinFunctionsIntegrationTestBase.java | 6 +-
...amSqlComparisonOperatorsIntegrationTest.java | 4 +-
.../extensions/sql/mock/MockedBoundedTable.java | 6 +-
.../sdk/extensions/sql/mock/MockedTable.java | 4 +-
.../sql/mock/MockedUnboundedTable.java | 4 +-
.../sql/schema/BeamSqlRowCoderTest.java | 2 +-
.../sql/schema/kafka/BeamKafkaCSVTableTest.java | 4 +-
.../sql/schema/text/BeamTextCSVTableTest.java | 4 +-
.../transform/BeamAggregationTransformTest.java | 10 +-
.../schema/transform/BeamTransformBaseTest.java | 8 +-
42 files changed, 368 insertions(+), 343 deletions(-)
----------------------------------------------------------------------