You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ta...@apache.org on 2017/06/16 00:43:11 UTC
[2/2] beam git commit: [BEAM-2442] This closes #3357
[BEAM-2442] This closes #3357
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/df5859d4
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/df5859d4
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/df5859d4
Branch: refs/heads/DSL_SQL
Commit: df5859d44dcd930a36e4996acd586037516edbb0
Parents: 2e92534 7bcbad5
Author: Tyler Akidau <ta...@apache.org>
Authored: Thu Jun 15 17:42:02 2017 -0700
Committer: Tyler Akidau <ta...@apache.org>
Committed: Thu Jun 15 17:42:02 2017 -0700
----------------------------------------------------------------------
.../java/org/apache/beam/dsls/sql/BeamSql.java | 19 ++--
.../org/apache/beam/dsls/sql/BeamSqlCli.java | 13 +--
.../org/apache/beam/dsls/sql/BeamSqlEnv.java | 52 ++++++++-
.../beam/dsls/sql/example/BeamSqlExample.java | 8 +-
.../beam/dsls/sql/rel/BeamAggregationRel.java | 11 +-
.../apache/beam/dsls/sql/rel/BeamFilterRel.java | 4 +-
.../beam/dsls/sql/rel/BeamProjectRel.java | 7 +-
.../apache/beam/dsls/sql/rel/BeamSortRel.java | 6 +-
.../apache/beam/dsls/sql/rel/BeamValuesRel.java | 3 +-
.../beam/dsls/sql/schema/BaseBeamTable.java | 70 +-----------
.../dsls/sql/schema/BeamPCollectionTable.java | 10 +-
.../beam/dsls/sql/schema/BeamSqlRecordType.java | 42 +-------
.../apache/beam/dsls/sql/schema/BeamSqlRow.java | 5 +-
.../beam/dsls/sql/schema/BeamSqlRowCoder.java | 6 +-
.../beam/dsls/sql/schema/BeamSqlTable.java | 52 +++++++++
.../beam/dsls/sql/schema/BeamTableUtils.java | 3 +-
.../sql/schema/kafka/BeamKafkaCSVTable.java | 9 +-
.../dsls/sql/schema/kafka/BeamKafkaTable.java | 12 ++-
.../beam/dsls/sql/schema/package-info.java | 1 -
.../dsls/sql/schema/text/BeamTextCSVTable.java | 10 +-
.../dsls/sql/schema/text/BeamTextTable.java | 9 +-
.../transform/BeamAggregationTransforms.java | 8 +-
.../beam/dsls/sql/utils/CalciteUtils.java | 108 +++++++++++++++++++
.../beam/dsls/sql/utils/package-info.java | 22 ++++
.../beam/dsls/sql/BeamSqlApiSurfaceTest.java | 59 ++++++++++
.../interpreter/BeamSqlFnExecutorTestBase.java | 3 +-
.../beam/dsls/sql/planner/BasePlanner.java | 22 ++--
.../BeamPlannerAggregationSubmitTest.java | 12 ++-
.../dsls/sql/planner/MockedBeamSqlTable.java | 11 +-
.../sql/schema/BeamPCollectionTableTest.java | 7 +-
.../dsls/sql/schema/BeamSqlRowCoderTest.java | 3 +-
.../sql/schema/kafka/BeamKafkaCSVTableTest.java | 19 ++--
.../sql/schema/text/BeamTextCSVTableTest.java | 12 ++-
.../transform/BeamAggregationTransformTest.java | 4 +-
.../schema/transform/BeamTransformBaseTest.java | 3 +-
35 files changed, 433 insertions(+), 212 deletions(-)
----------------------------------------------------------------------