beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rober...@apache.org
Subject [7/7] beam git commit: Closes #3675
Date Fri, 04 Aug 2017 17:09:50 GMT
Closes #3675


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

Branch: refs/heads/DSL_SQL
Commit: 8f922f74b693795f25d7c2d4a9da9ea3de5a92eb
Parents: 10962a3 89109b8
Author: Robert Bradshaw <robertwb@gmail.com>
Authored: Fri Aug 4 10:08:38 2017 -0700
Committer: Robert Bradshaw <robertwb@gmail.com>
Committed: Fri Aug 4 10:08:38 2017 -0700

----------------------------------------------------------------------
 .../apache/beam/sdk/coders/BeamRecordCoder.java |  98 ++++++
 .../org/apache/beam/sdk/values/BeamRecord.java  | 267 ++++++++++++++++
 .../apache/beam/sdk/values/BeamRecordType.java  |  70 +++++
 .../apache/beam/sdk/extensions/sql/BeamSql.java |  22 +-
 .../beam/sdk/extensions/sql/BeamSqlCli.java     |  10 +-
 .../beam/sdk/extensions/sql/BeamSqlEnv.java     |   6 +-
 .../extensions/sql/example/BeamSqlExample.java  |  27 +-
 .../interpreter/BeamSqlExpressionExecutor.java  |   6 +-
 .../sql/impl/interpreter/BeamSqlFnExecutor.java |   6 +-
 .../operator/BeamSqlCaseExpression.java         |   4 +-
 .../operator/BeamSqlCastExpression.java         |   4 +-
 .../interpreter/operator/BeamSqlExpression.java |   8 +-
 .../operator/BeamSqlInputRefExpression.java     |   4 +-
 .../interpreter/operator/BeamSqlPrimitive.java  |   6 +-
 .../operator/BeamSqlReinterpretExpression.java  |   4 +-
 .../operator/BeamSqlUdfExpression.java          |   4 +-
 .../operator/BeamSqlWindowEndExpression.java    |   4 +-
 .../operator/BeamSqlWindowExpression.java       |   4 +-
 .../operator/BeamSqlWindowStartExpression.java  |   4 +-
 .../arithmetic/BeamSqlArithmeticExpression.java |   4 +-
 .../comparison/BeamSqlCompareExpression.java    |   4 +-
 .../comparison/BeamSqlIsNotNullExpression.java  |   4 +-
 .../comparison/BeamSqlIsNullExpression.java     |   4 +-
 .../date/BeamSqlCurrentDateExpression.java      |   4 +-
 .../date/BeamSqlCurrentTimeExpression.java      |   4 +-
 .../date/BeamSqlCurrentTimestampExpression.java |   4 +-
 .../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      |   4 +-
 .../operator/math/BeamSqlRandExpression.java    |   4 +-
 .../math/BeamSqlRandIntegerExpression.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 +-
 .../sql/impl/planner/BeamQueryPlanner.java      |   4 +-
 .../sql/impl/rel/BeamAggregationRel.java        |  38 +--
 .../extensions/sql/impl/rel/BeamFilterRel.java  |  11 +-
 .../extensions/sql/impl/rel/BeamIOSinkRel.java  |   6 +-
 .../sql/impl/rel/BeamIOSourceRel.java           |  13 +-
 .../sql/impl/rel/BeamIntersectRel.java          |   4 +-
 .../extensions/sql/impl/rel/BeamJoinRel.java    |  75 +++--
 .../extensions/sql/impl/rel/BeamMinusRel.java   |   4 +-
 .../extensions/sql/impl/rel/BeamProjectRel.java |  11 +-
 .../extensions/sql/impl/rel/BeamRelNode.java    |   4 +-
 .../sql/impl/rel/BeamSetOperatorRelBase.java    |  18 +-
 .../extensions/sql/impl/rel/BeamSortRel.java    |  49 ++-
 .../extensions/sql/impl/rel/BeamUnionRel.java   |   4 +-
 .../extensions/sql/impl/rel/BeamValuesRel.java  |  15 +-
 .../transform/BeamAggregationTransforms.java    |  47 +--
 .../sql/impl/transform/BeamJoinTransforms.java  |  65 ++--
 .../transform/BeamSetOperatorsTransforms.java   |  24 +-
 .../sql/impl/transform/BeamSqlFilterFn.java     |   6 +-
 .../transform/BeamSqlOutputToConsoleFn.java     |   4 +-
 .../sql/impl/transform/BeamSqlProjectFn.java    |  14 +-
 .../extensions/sql/impl/utils/CalciteUtils.java |  10 +-
 .../extensions/sql/schema/BaseBeamTable.java    |   6 +-
 .../sql/schema/BeamPCollectionTable.java        |  13 +-
 .../sql/schema/BeamSqlRecordHelper.java         | 217 +++++++++++++
 .../sql/schema/BeamSqlRecordType.java           | 168 ++++++++++
 .../sdk/extensions/sql/schema/BeamSqlRow.java   | 314 -------------------
 .../extensions/sql/schema/BeamSqlRowCoder.java  | 185 -----------
 .../extensions/sql/schema/BeamSqlRowType.java   |  40 ---
 .../sdk/extensions/sql/schema/BeamSqlTable.java |   7 +-
 .../extensions/sql/schema/BeamTableUtils.java   |  14 +-
 .../sql/schema/kafka/BeamKafkaCSVTable.java     |  38 +--
 .../sql/schema/kafka/BeamKafkaTable.java        |  20 +-
 .../sql/schema/text/BeamTextCSVTable.java       |  12 +-
 .../schema/text/BeamTextCSVTableIOReader.java   |  14 +-
 .../schema/text/BeamTextCSVTableIOWriter.java   |  16 +-
 .../sql/schema/text/BeamTextTable.java          |   4 +-
 .../sql/BeamSqlDslAggregationTest.java          |  80 ++---
 .../beam/sdk/extensions/sql/BeamSqlDslBase.java |  51 ++-
 .../extensions/sql/BeamSqlDslFilterTest.java    |  26 +-
 .../sdk/extensions/sql/BeamSqlDslJoinTest.java  |  26 +-
 .../extensions/sql/BeamSqlDslProjectTest.java   |  64 ++--
 .../extensions/sql/BeamSqlDslUdfUdafTest.java   |  24 +-
 .../beam/sdk/extensions/sql/TestUtils.java      |  30 +-
 .../interpreter/BeamSqlFnExecutorTestBase.java  |  10 +-
 .../sql/impl/rel/BeamIntersectRelTest.java      |   6 +-
 .../rel/BeamJoinRelBoundedVsBoundedTest.java    |  10 +-
 .../rel/BeamJoinRelUnboundedVsBoundedTest.java  |  10 +-
 .../BeamJoinRelUnboundedVsUnboundedTest.java    |  10 +-
 .../sql/impl/rel/BeamMinusRelTest.java          |   6 +-
 .../impl/rel/BeamSetOperatorRelBaseTest.java    |   4 +-
 .../sql/impl/rel/BeamSortRelTest.java           |  12 +-
 .../sql/impl/rel/BeamUnionRelTest.java          |   6 +-
 .../sql/impl/rel/BeamValuesRelTest.java         |   8 +-
 .../sdk/extensions/sql/impl/rel/CheckSize.java  |   8 +-
 ...mSqlBuiltinFunctionsIntegrationTestBase.java |  17 +-
 ...amSqlComparisonOperatorsIntegrationTest.java |  11 +-
 .../BeamSqlDateFunctionsIntegrationTest.java    |  12 +-
 .../extensions/sql/mock/MockedBoundedTable.java |  24 +-
 .../sdk/extensions/sql/mock/MockedTable.java    |   8 +-
 .../sql/mock/MockedUnboundedTable.java          |  18 +-
 .../sql/schema/BeamSqlRowCoderTest.java         |   8 +-
 .../sql/schema/kafka/BeamKafkaCSVTableTest.java |  14 +-
 .../sql/schema/text/BeamTextCSVTableTest.java   |  16 +-
 .../transform/BeamAggregationTransformTest.java |  72 ++---
 .../schema/transform/BeamTransformBaseTest.java |  18 +-
 111 files changed, 1519 insertions(+), 1250 deletions(-)
----------------------------------------------------------------------



Mime
View raw message