[BEAM-2744] This closes #3702
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2a1377e1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2a1377e1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2a1377e1 Branch: refs/heads/DSL_SQL Commit: 2a1377e1c3aae2234f20b38c2203a2d8d7c78f6b Parents: be01be5 affb8f6 Author: Tyler Akidau <[email protected]> Authored: Thu Aug 10 13:23:37 2017 -0700 Committer: Tyler Akidau <[email protected]> Committed: Thu Aug 10 13:23:37 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/coders/BeamRecordCoder.java | 12 +++++------ .../org/apache/beam/sdk/values/BeamRecord.java | 22 +++++--------------- .../apache/beam/sdk/values/BeamRecordType.java | 7 ++++++- .../extensions/sql/impl/rel/BeamJoinRel.java | 2 +- .../extensions/sql/impl/rel/BeamValuesRel.java | 2 +- .../sql/impl/transform/BeamJoinTransforms.java | 4 ++-- .../extensions/sql/schema/BeamTableUtils.java | 10 ++++----- .../sql/BeamSqlDslAggregationTest.java | 16 +++++++------- .../beam/sdk/extensions/sql/TestUtils.java | 6 +++--- 9 files changed, 38 insertions(+), 43 deletions(-) ----------------------------------------------------------------------
