beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [3/3] beam git commit: [BEAM-2010] expose programming interface
Date Mon, 05 Jun 2017 23:34:54 GMT
[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 <lcwik@google.com>
Authored: Mon Jun 5 16:34:41 2017 -0700
Committer: Luke Cwik <lcwik@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(-)
----------------------------------------------------------------------



Mime
View raw message