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 <[email protected]> Authored: Fri Aug 4 10:08:38 2017 -0700 Committer: Robert Bradshaw <[email protected]> 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(-) ----------------------------------------------------------------------
