beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [5/5] beam git commit: [BEAM-2433] unify SQL/Sql words in class name
Date Mon, 12 Jun 2017 14:48:42 GMT
[BEAM-2433] unify SQL/Sql words in class name

This closes #3340


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e68badd4
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e68badd4
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e68badd4

Branch: refs/heads/DSL_SQL
Commit: e68badd4d1d25e10e68900bc07077d2f556ef30d
Parents: 5c1f2cb 743f0b3
Author: Luke Cwik <lcwik@google.com>
Authored: Mon Jun 12 07:48:23 2017 -0700
Committer: Luke Cwik <lcwik@google.com>
Committed: Mon Jun 12 07:48:23 2017 -0700

----------------------------------------------------------------------
 .../java/org/apache/beam/dsls/sql/BeamSql.java  |  20 +-
 .../org/apache/beam/dsls/sql/BeamSqlCli.java    |   8 +-
 .../beam/dsls/sql/example/BeamSqlExample.java   |  16 +-
 .../interpreter/BeamSQLExpressionExecutor.java  |  43 ---
 .../dsls/sql/interpreter/BeamSQLFnExecutor.java | 235 ------------
 .../interpreter/BeamSqlExpressionExecutor.java  |  43 +++
 .../dsls/sql/interpreter/BeamSqlFnExecutor.java | 235 ++++++++++++
 .../operator/BeamSqlAndExpression.java          |   4 +-
 .../operator/BeamSqlCaseExpression.java         |   4 +-
 .../operator/BeamSqlCompareExpression.java      |   4 +-
 .../interpreter/operator/BeamSqlExpression.java |   8 +-
 .../operator/BeamSqlInputRefExpression.java     |   4 +-
 .../operator/BeamSqlIsNotNullExpression.java    |   4 +-
 .../operator/BeamSqlIsNullExpression.java       |   4 +-
 .../operator/BeamSqlOrExpression.java           |   4 +-
 .../interpreter/operator/BeamSqlPrimitive.java  |   6 +-
 .../operator/BeamSqlUdfExpression.java          |   4 +-
 .../operator/BeamSqlWindowEndExpression.java    |   4 +-
 .../operator/BeamSqlWindowExpression.java       |   4 +-
 .../operator/BeamSqlWindowStartExpression.java  |   4 +-
 .../arithmetic/BeamSqlArithmeticExpression.java |   6 +-
 .../math/BeamSqlMathUnaryExpression.java        |   4 +-
 .../string/BeamSqlCharLengthExpression.java     |   4 +-
 .../string/BeamSqlConcatExpression.java         |   4 +-
 .../string/BeamSqlInitCapExpression.java        |   4 +-
 .../operator/string/BeamSqlLowerExpression.java |   4 +-
 .../string/BeamSqlOverlayExpression.java        |   4 +-
 .../string/BeamSqlPositionExpression.java       |   4 +-
 .../string/BeamSqlSubstringExpression.java      |   4 +-
 .../operator/string/BeamSqlTrimExpression.java  |   4 +-
 .../operator/string/BeamSqlUpperExpression.java |   4 +-
 .../beam/dsls/sql/planner/BeamQueryPlanner.java |   4 +-
 .../beam/dsls/sql/planner/BeamSQLRelUtils.java  |  74 ----
 .../beam/dsls/sql/planner/BeamSqlRelUtils.java  |  74 ++++
 .../beam/dsls/sql/rel/BeamAggregationRel.java   |  58 +--
 .../apache/beam/dsls/sql/rel/BeamFilterRel.java |  28 +-
 .../apache/beam/dsls/sql/rel/BeamIOSinkRel.java |  12 +-
 .../beam/dsls/sql/rel/BeamIOSourceRel.java      |  14 +-
 .../beam/dsls/sql/rel/BeamProjectRel.java       |  28 +-
 .../apache/beam/dsls/sql/rel/BeamRelNode.java   |   4 +-
 .../apache/beam/dsls/sql/rel/BeamSortRel.java   |  32 +-
 .../apache/beam/dsls/sql/rel/BeamValuesRel.java |  16 +-
 .../beam/dsls/sql/schema/BaseBeamTable.java     |  10 +-
 .../dsls/sql/schema/BeamPCollectionTable.java   |  10 +-
 .../beam/dsls/sql/schema/BeamSQLRecordType.java |  97 -----
 .../apache/beam/dsls/sql/schema/BeamSQLRow.java | 367 -------------------
 .../beam/dsls/sql/schema/BeamSqlRecordType.java |  96 +++++
 .../apache/beam/dsls/sql/schema/BeamSqlRow.java | 367 +++++++++++++++++++
 .../beam/dsls/sql/schema/BeamSqlRowCoder.java   |  16 +-
 .../beam/dsls/sql/schema/BeamTableUtils.java    |  10 +-
 .../sql/schema/kafka/BeamKafkaCSVTable.java     |  42 +--
 .../dsls/sql/schema/kafka/BeamKafkaTable.java   |  16 +-
 .../dsls/sql/schema/text/BeamTextCSVTable.java  |   6 +-
 .../schema/text/BeamTextCSVTableIOReader.java   |  18 +-
 .../schema/text/BeamTextCSVTableIOWriter.java   |  20 +-
 .../transform/BeamAggregationTransforms.java    |  56 +--
 .../dsls/sql/transform/BeamSQLFilterFn.java     |  62 ----
 .../sql/transform/BeamSQLOutputToConsoleFn.java |  41 ---
 .../dsls/sql/transform/BeamSQLProjectFn.java    |  72 ----
 .../dsls/sql/transform/BeamSqlFilterFn.java     |  62 ++++
 .../sql/transform/BeamSqlOutputToConsoleFn.java |  41 +++
 .../dsls/sql/transform/BeamSqlProjectFn.java    |  72 ++++
 .../beam/dsls/sql/transform/package-info.java   |   2 +-
 .../sql/interpreter/BeamSQLFnExecutorTest.java  | 268 --------------
 .../interpreter/BeamSQLFnExecutorTestBase.java  |  91 -----
 .../sql/interpreter/BeamSqlFnExecutorTest.java  | 268 ++++++++++++++
 .../interpreter/BeamSqlFnExecutorTestBase.java  |  91 +++++
 .../operator/BeamNullExperssionTest.java        |   4 +-
 .../operator/BeamSqlAndOrExpressionTest.java    |   4 +-
 .../operator/BeamSqlCaseExpressionTest.java     |   4 +-
 .../operator/BeamSqlCompareExpressionTest.java  |   4 +-
 .../operator/BeamSqlInputRefExpressionTest.java |   4 +-
 .../operator/BeamSqlPrimitiveTest.java          |   4 +-
 .../operator/BeamSqlUdfExpressionTest.java      |   4 +-
 .../BeamSqlArithmeticExpressionTest.java        |   4 +-
 .../math/BeamSqlMathUnaryExpressionTest.java    |   4 +-
 .../string/BeamSqlCharLengthExpressionTest.java |   4 +-
 .../string/BeamSqlConcatExpressionTest.java     |   4 +-
 .../string/BeamSqlInitCapExpressionTest.java    |   4 +-
 .../string/BeamSqlLowerExpressionTest.java      |   4 +-
 .../string/BeamSqlOverlayExpressionTest.java    |   4 +-
 .../string/BeamSqlPositionExpressionTest.java   |   4 +-
 .../string/BeamSqlSubstringExpressionTest.java  |   4 +-
 .../string/BeamSqlTrimExpressionTest.java       |   4 +-
 .../string/BeamSqlUpperExpressionTest.java      |   4 +-
 .../beam/dsls/sql/planner/BasePlanner.java      |  16 +-
 .../sql/planner/BeamGroupByPipelineTest.java    |  16 +-
 .../sql/planner/BeamInvalidGroupByTest.java     |   6 +-
 .../BeamPlannerAggregationSubmitTest.java       |  28 +-
 .../dsls/sql/planner/BeamPlannerSubmitTest.java |  10 +-
 .../dsls/sql/planner/MockedBeamSQLTable.java    | 161 --------
 .../dsls/sql/planner/MockedBeamSqlTable.java    | 161 ++++++++
 .../beam/dsls/sql/rel/BeamSortRelTest.java      |  44 +--
 .../beam/dsls/sql/rel/BeamValuesRelTest.java    |  22 +-
 .../sql/schema/BeamPCollectionTableTest.java    |   6 +-
 .../dsls/sql/schema/BeamSqlRowCoderTest.java    |   4 +-
 .../sql/schema/kafka/BeamKafkaCSVTableTest.java |  16 +-
 .../sql/schema/text/BeamTextCSVTableTest.java   |  18 +-
 .../transform/BeamAggregationTransformTest.java |  56 +--
 .../schema/transform/BeamTransformBaseTest.java |  22 +-
 100 files changed, 1953 insertions(+), 1954 deletions(-)
----------------------------------------------------------------------



Mime
View raw message