[BEAM-2234] This closes #3135
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/868bcbda Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/868bcbda Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/868bcbda Branch: refs/heads/DSL_SQL Commit: 868bcbdad30a2232889d7d439b5190862ae48421 Parents: 8bb5984 d74a5c3 Author: Jean-Baptiste Onofré <[email protected]> Authored: Sun May 14 07:52:39 2017 +0200 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Sun May 14 07:52:39 2017 +0200 ---------------------------------------------------------------------- .../beam/dsls/sql/planner/BeamPipelineCreator.java | 15 --------------- .../beam/dsls/sql/planner/BeamQueryPlanner.java | 4 +++- .../beam/dsls/sql/rel/BeamAggregationRel.java | 12 +++++------- .../apache/beam/dsls/sql/rel/BeamFilterRel.java | 14 ++++++-------- .../apache/beam/dsls/sql/rel/BeamIOSinkRel.java | 17 ++++++++--------- .../apache/beam/dsls/sql/rel/BeamIOSourceRel.java | 8 +++----- .../apache/beam/dsls/sql/rel/BeamProjectRel.java | 13 +++++-------- .../org/apache/beam/dsls/sql/rel/BeamRelNode.java | 11 +++++------ 8 files changed, 35 insertions(+), 59 deletions(-) ----------------------------------------------------------------------
