[BEAM-2730] This closes #3692
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/66286749 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/66286749 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/66286749 Branch: refs/heads/DSL_SQL Commit: 66286749f2d64eb3f25d99b4d9bf56c49d9f62b6 Parents: 926c70a fa36b12 Author: Tyler Akidau <taki...@apache.org> Authored: Tue Aug 8 19:07:56 2017 -0700 Committer: Tyler Akidau <taki...@apache.org> Committed: Tue Aug 8 19:07:56 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/coders/BeamRecordCoder.java | 10 +- .../org/apache/beam/sdk/values/BeamRecord.java | 24 ++--- .../extensions/sql/example/BeamSqlExample.java | 5 +- .../extensions/sql/impl/rel/BeamJoinRel.java | 7 +- .../extensions/sql/impl/rel/BeamValuesRel.java | 7 +- .../transform/BeamAggregationTransforms.java | 26 +++-- .../sql/impl/transform/BeamJoinTransforms.java | 20 ++-- .../sql/impl/transform/BeamSqlProjectFn.java | 9 +- .../sql/schema/BeamSqlRecordType.java | 5 +- .../extensions/sql/schema/BeamTableUtils.java | 41 +++---- .../sql/BeamSqlDslAggregationTest.java | 107 ++++--------------- .../beam/sdk/extensions/sql/BeamSqlDslBase.java | 56 +++------- .../extensions/sql/BeamSqlDslProjectTest.java | 48 ++++----- .../extensions/sql/BeamSqlDslUdfUdafTest.java | 8 +- .../beam/sdk/extensions/sql/TestUtils.java | 6 +- .../interpreter/BeamSqlFnExecutorTestBase.java | 8 +- .../sql/schema/BeamSqlRowCoderTest.java | 16 +-- .../sql/schema/kafka/BeamKafkaCSVTableTest.java | 12 +-- 18 files changed, 132 insertions(+), 283 deletions(-) ----------------------------------------------------------------------