You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lz...@apache.org on 2017/07/19 02:06:43 UTC
[3/3] beam git commit: This closes #3571
This closes #3571
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d4d615a7
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d4d615a7
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d4d615a7
Branch: refs/heads/DSL_SQL
Commit: d4d615a7237729f5e59085ae2bd77541c6ea7ddb
Parents: a1f7cf6 a9c8a8a
Author: JingsongLi <lz...@aliyun.com>
Authored: Wed Jul 19 10:06:04 2017 +0800
Committer: JingsongLi <lz...@aliyun.com>
Committed: Wed Jul 19 10:06:04 2017 +0800
----------------------------------------------------------------------
.../org/apache/beam/dsls/sql/BeamSqlEnv.java | 12 +++---
.../beam/dsls/sql/example/BeamSqlExample.java | 4 +-
.../interpreter/BeamSqlExpressionExecutor.java | 2 +-
.../dsls/sql/interpreter/BeamSqlFnExecutor.java | 4 +-
.../operator/BeamSqlCaseExpression.java | 8 ++--
.../operator/BeamSqlCastExpression.java | 22 +++++------
.../operator/BeamSqlCompareExpression.java | 6 +--
.../interpreter/operator/BeamSqlExpression.java | 2 +-
.../operator/BeamSqlInputRefExpression.java | 4 +-
.../operator/BeamSqlIsNotNullExpression.java | 4 +-
.../operator/BeamSqlIsNullExpression.java | 4 +-
.../interpreter/operator/BeamSqlPrimitive.java | 2 +-
.../operator/BeamSqlReinterpretExpression.java | 6 +--
.../operator/BeamSqlUdfExpression.java | 4 +-
.../operator/BeamSqlWindowEndExpression.java | 4 +-
.../operator/BeamSqlWindowExpression.java | 4 +-
.../operator/BeamSqlWindowStartExpression.java | 4 +-
.../arithmetic/BeamSqlArithmeticExpression.java | 6 +--
.../date/BeamSqlCurrentDateExpression.java | 2 +-
.../date/BeamSqlCurrentTimeExpression.java | 2 +-
.../date/BeamSqlCurrentTimestampExpression.java | 2 +-
.../date/BeamSqlDateCeilExpression.java | 4 +-
.../date/BeamSqlDateFloorExpression.java | 4 +-
.../operator/date/BeamSqlExtractExpression.java | 4 +-
.../operator/logical/BeamSqlAndExpression.java | 4 +-
.../operator/logical/BeamSqlNotExpression.java | 4 +-
.../operator/logical/BeamSqlOrExpression.java | 4 +-
.../math/BeamSqlMathBinaryExpression.java | 4 +-
.../math/BeamSqlMathUnaryExpression.java | 4 +-
.../operator/math/BeamSqlPiExpression.java | 2 +-
.../string/BeamSqlCharLengthExpression.java | 4 +-
.../string/BeamSqlConcatExpression.java | 6 +--
.../string/BeamSqlInitCapExpression.java | 4 +-
.../operator/string/BeamSqlLowerExpression.java | 4 +-
.../string/BeamSqlOverlayExpression.java | 10 ++---
.../string/BeamSqlPositionExpression.java | 8 ++--
.../string/BeamSqlSubstringExpression.java | 8 ++--
.../operator/string/BeamSqlTrimExpression.java | 10 ++---
.../operator/string/BeamSqlUpperExpression.java | 4 +-
.../beam/dsls/sql/rel/BeamAggregationRel.java | 22 +++++------
.../apache/beam/dsls/sql/rel/BeamFilterRel.java | 2 +-
.../beam/dsls/sql/rel/BeamIOSourceRel.java | 2 +-
.../apache/beam/dsls/sql/rel/BeamJoinRel.java | 12 +++---
.../beam/dsls/sql/rel/BeamProjectRel.java | 4 +-
.../apache/beam/dsls/sql/rel/BeamSortRel.java | 2 +-
.../apache/beam/dsls/sql/rel/BeamValuesRel.java | 9 ++---
.../beam/dsls/sql/schema/BaseBeamTable.java | 10 ++---
.../dsls/sql/schema/BeamPCollectionTable.java | 8 ++--
.../beam/dsls/sql/schema/BeamSqlRecordType.java | 40 --------------------
.../apache/beam/dsls/sql/schema/BeamSqlRow.java | 10 ++---
.../beam/dsls/sql/schema/BeamSqlRowCoder.java | 6 +--
.../beam/dsls/sql/schema/BeamSqlRowType.java | 40 ++++++++++++++++++++
.../beam/dsls/sql/schema/BeamSqlTable.java | 2 +-
.../beam/dsls/sql/schema/BeamTableUtils.java | 10 ++---
.../sql/schema/kafka/BeamKafkaCSVTable.java | 29 +++++++-------
.../dsls/sql/schema/kafka/BeamKafkaTable.java | 11 +++---
.../dsls/sql/schema/text/BeamTextCSVTable.java | 14 +++----
.../schema/text/BeamTextCSVTableIOReader.java | 11 +++---
.../schema/text/BeamTextCSVTableIOWriter.java | 9 ++---
.../dsls/sql/schema/text/BeamTextTable.java | 6 +--
.../transform/BeamAggregationTransforms.java | 26 ++++++-------
.../dsls/sql/transform/BeamJoinTransforms.java | 6 +--
.../dsls/sql/transform/BeamSqlProjectFn.java | 16 ++++----
.../beam/dsls/sql/utils/CalciteUtils.java | 12 +++---
.../dsls/sql/BeamSqlDslAggregationTest.java | 14 +++----
.../apache/beam/dsls/sql/BeamSqlDslBase.java | 26 ++++++-------
.../beam/dsls/sql/BeamSqlDslJoinTest.java | 10 ++---
.../beam/dsls/sql/BeamSqlDslProjectTest.java | 10 ++---
.../beam/dsls/sql/BeamSqlDslUdfUdafTest.java | 6 +--
.../org/apache/beam/dsls/sql/TestUtils.java | 28 +++++++-------
...mSqlBuiltinFunctionsIntegrationTestBase.java | 6 +--
.../interpreter/BeamSqlFnExecutorTestBase.java | 8 ++--
.../beam/dsls/sql/mock/MockedBoundedTable.java | 14 +++----
.../apache/beam/dsls/sql/mock/MockedTable.java | 6 +--
.../dsls/sql/mock/MockedUnboundedTable.java | 14 +++----
.../dsls/sql/schema/BeamSqlRowCoderTest.java | 6 +--
.../sql/schema/kafka/BeamKafkaCSVTableTest.java | 7 ++--
.../sql/schema/text/BeamTextCSVTableTest.java | 17 ++++-----
.../transform/BeamAggregationTransformTest.java | 13 +++----
.../schema/transform/BeamTransformBaseTest.java | 12 +++---
80 files changed, 354 insertions(+), 362 deletions(-)
----------------------------------------------------------------------