[BEAM-2010] expose programming interface This closes #3250
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9395fbb3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9395fbb3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9395fbb3 Branch: refs/heads/DSL_SQL Commit: 9395fbb3c8d747b53244fc54a582acfd3e106d76 Parents: dedabff 680a543 Author: Luke Cwik <[email protected]> Authored: Mon Jun 5 16:34:41 2017 -0700 Committer: Luke Cwik <[email protected]> Committed: Mon Jun 5 16:34:41 2017 -0700 ---------------------------------------------------------------------- .../beam/dsls/sql/BeamSQLEnvironment.java | 142 ---------------- .../java/org/apache/beam/dsls/sql/BeamSql.java | 166 +++++++++++++++++++ .../org/apache/beam/dsls/sql/BeamSqlCli.java | 70 ++++++++ .../org/apache/beam/dsls/sql/BeamSqlEnv.java | 63 +++++++ .../beam/dsls/sql/example/BeamSqlExample.java | 106 +++++------- .../dsls/sql/planner/BeamPipelineCreator.java | 17 +- .../beam/dsls/sql/planner/BeamQueryPlanner.java | 21 ++- .../beam/dsls/sql/rel/BeamAggregationRel.java | 57 +++++-- .../apache/beam/dsls/sql/rel/BeamFilterRel.java | 12 +- .../apache/beam/dsls/sql/rel/BeamIOSinkRel.java | 17 +- .../beam/dsls/sql/rel/BeamIOSourceRel.java | 25 ++- .../beam/dsls/sql/rel/BeamProjectRel.java | 11 +- .../apache/beam/dsls/sql/rel/BeamRelNode.java | 11 +- .../apache/beam/dsls/sql/rel/BeamSortRel.java | 19 ++- .../apache/beam/dsls/sql/rel/BeamValuesRel.java | 10 +- .../beam/dsls/sql/schema/BeamSQLRecordType.java | 22 +++ .../dsls/sql/schema/BeamSQLRecordTypeCoder.java | 87 ---------- .../beam/dsls/sql/schema/BeamSqlRowCoder.java | 34 ++-- .../beam/dsls/sql/planner/BasePlanner.java | 10 +- .../sql/planner/BeamGroupByExplainTest.java | 18 +- .../sql/planner/BeamGroupByPipelineTest.java | 18 +- .../sql/planner/BeamInvalidGroupByTest.java | 5 +- .../BeamPlannerAggregationSubmitTest.java | 12 +- .../sql/planner/BeamPlannerExplainTest.java | 7 +- .../dsls/sql/planner/BeamPlannerSubmitTest.java | 3 +- .../beam/dsls/sql/rel/BeamSortRelTest.java | 28 ++-- .../beam/dsls/sql/rel/BeamValuesRelTest.java | 14 +- .../sql/schema/BeamPCollectionTableTest.java | 18 +- .../dsls/sql/schema/BeamSqlRowCoderTest.java | 2 +- .../transform/BeamAggregationTransformTest.java | 98 ++++++----- 30 files changed, 628 insertions(+), 495 deletions(-) ----------------------------------------------------------------------
