You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/06/05 23:34:54 UTC
[3/3] beam git commit: [BEAM-2010] expose programming interface
[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 <lc...@google.com>
Authored: Mon Jun 5 16:34:41 2017 -0700
Committer: Luke Cwik <lc...@google.com>
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(-)
----------------------------------------------------------------------