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 1675b0f843ed34de8ba6f3676f794db80b40139d Merge: 6fa7455 4396164 Author: Kenn Knowles <[email protected]> AuthorDate: Wed Jun 20 10:08:22 2018 -0700 Merge pull request #5694: Make BeamRelNode take a PCollectionList<Row> always .../sql/impl/rel/BeamAggregationRel.java | 16 ++++++--- .../sdk/extensions/sql/impl/rel/BeamCalcRel.java | 16 ++++++--- .../sdk/extensions/sql/impl/rel/BeamIOSinkRel.java | 17 +++++++--- .../extensions/sql/impl/rel/BeamIOSourceRel.java | 18 ++++++---- .../extensions/sql/impl/rel/BeamIntersectRel.java | 4 +-- .../sdk/extensions/sql/impl/rel/BeamJoinRel.java | 38 ++++++++++++---------- .../sdk/extensions/sql/impl/rel/BeamMinusRel.java | 4 +-- .../sdk/extensions/sql/impl/rel/BeamRelNode.java | 23 +++---------- .../sql/impl/rel/BeamSetOperatorRelBase.java | 14 +++++--- .../sdk/extensions/sql/impl/rel/BeamSortRel.java | 17 +++++++--- .../extensions/sql/impl/rel/BeamSqlRelUtils.java | 23 ++++++++++--- .../extensions/sql/impl/rel/BeamUncollectRel.java | 18 +++++++--- .../sdk/extensions/sql/impl/rel/BeamUnionRel.java | 4 +-- .../sdk/extensions/sql/impl/rel/BeamUnnestRel.java | 17 ++++------ .../sdk/extensions/sql/impl/rel/BeamValuesRel.java | 17 ++++++---- 15 files changed, 148 insertions(+), 98 deletions(-)
