You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2017/08/04 17:09:50 UTC
[7/7] beam git commit: Closes #3675
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 <ro...@gmail.com>
Authored: Fri Aug 4 10:08:38 2017 -0700
Committer: Robert Bradshaw <ro...@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(-)
----------------------------------------------------------------------