[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 <taki...@apache.org> Authored: Wed Aug 9 09:38:45 2017 -0700 Committer: Tyler Akidau <taki...@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(-) ----------------------------------------------------------------------