beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From taki...@apache.org
Subject [2/2] beam git commit: [BEAM-2442] This closes #3357
Date Fri, 16 Jun 2017 00:43:11 GMT
[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 <takidau@apache.org>
Authored: Thu Jun 15 17:42:02 2017 -0700
Committer: Tyler Akidau <takidau@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(-)
----------------------------------------------------------------------



Mime
View raw message