You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ta...@apache.org on 2017/08/02 05:09:22 UTC
[59/59] beam git commit: [BEAM-2441] This closes #3666
[BEAM-2441] This closes #3666
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/10962a34
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/10962a34
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/10962a34
Branch: refs/heads/DSL_SQL
Commit: 10962a34d3727f5ee2ee8df030847765e8eaab63
Parents: d32aea9 febd044
Author: Tyler Akidau <ta...@apache.org>
Authored: Tue Aug 1 22:06:25 2017 -0700
Committer: Tyler Akidau <ta...@apache.org>
Committed: Tue Aug 1 22:06:25 2017 -0700
----------------------------------------------------------------------
dsls/pom.xml | 60 ---
dsls/sql/pom.xml | 226 ---------
.../java/org/apache/beam/dsls/sql/BeamSql.java | 244 ----------
.../org/apache/beam/dsls/sql/BeamSqlCli.java | 65 ---
.../org/apache/beam/dsls/sql/BeamSqlEnv.java | 120 -----
.../beam/dsls/sql/example/BeamSqlExample.java | 97 ----
.../beam/dsls/sql/example/package-info.java | 23 -
.../interpreter/BeamSqlExpressionExecutor.java | 43 --
.../dsls/sql/interpreter/BeamSqlFnExecutor.java | 442 ------------------
.../operator/BeamSqlCaseExpression.java | 64 ---
.../operator/BeamSqlCastExpression.java | 132 ------
.../interpreter/operator/BeamSqlExpression.java | 78 ----
.../operator/BeamSqlInputRefExpression.java | 43 --
.../interpreter/operator/BeamSqlPrimitive.java | 152 -------
.../operator/BeamSqlReinterpretExpression.java | 55 ---
.../operator/BeamSqlUdfExpression.java | 86 ----
.../operator/BeamSqlWindowEndExpression.java | 42 --
.../operator/BeamSqlWindowExpression.java | 50 --
.../operator/BeamSqlWindowStartExpression.java | 43 --
.../arithmetic/BeamSqlArithmeticExpression.java | 122 -----
.../arithmetic/BeamSqlDivideExpression.java | 37 --
.../arithmetic/BeamSqlMinusExpression.java | 36 --
.../arithmetic/BeamSqlModExpression.java | 36 --
.../arithmetic/BeamSqlMultiplyExpression.java | 36 --
.../arithmetic/BeamSqlPlusExpression.java | 36 --
.../operator/arithmetic/package-info.java | 22 -
.../comparison/BeamSqlCompareExpression.java | 96 ----
.../comparison/BeamSqlEqualsExpression.java | 49 --
.../BeamSqlGreaterThanExpression.java | 49 --
.../BeamSqlGreaterThanOrEqualsExpression.java | 49 --
.../comparison/BeamSqlIsNotNullExpression.java | 53 ---
.../comparison/BeamSqlIsNullExpression.java | 53 ---
.../comparison/BeamSqlLessThanExpression.java | 49 --
.../BeamSqlLessThanOrEqualsExpression.java | 49 --
.../comparison/BeamSqlNotEqualsExpression.java | 49 --
.../operator/comparison/package-info.java | 22 -
.../date/BeamSqlCurrentDateExpression.java | 45 --
.../date/BeamSqlCurrentTimeExpression.java | 53 ---
.../date/BeamSqlCurrentTimestampExpression.java | 49 --
.../date/BeamSqlDateCeilExpression.java | 55 ---
.../date/BeamSqlDateFloorExpression.java | 55 ---
.../operator/date/BeamSqlExtractExpression.java | 101 -----
.../interpreter/operator/date/package-info.java | 22 -
.../operator/logical/BeamSqlAndExpression.java | 48 --
.../logical/BeamSqlLogicalExpression.java | 47 --
.../operator/logical/BeamSqlNotExpression.java | 54 ---
.../operator/logical/BeamSqlOrExpression.java | 48 --
.../operator/logical/package-info.java | 22 -
.../operator/math/BeamSqlAbsExpression.java | 74 ---
.../operator/math/BeamSqlAcosExpression.java | 41 --
.../operator/math/BeamSqlAsinExpression.java | 41 --
.../operator/math/BeamSqlAtan2Expression.java | 43 --
.../operator/math/BeamSqlAtanExpression.java | 41 --
.../operator/math/BeamSqlCeilExpression.java | 46 --
.../operator/math/BeamSqlCosExpression.java | 41 --
.../operator/math/BeamSqlCotExpression.java | 41 --
.../operator/math/BeamSqlDegreesExpression.java | 41 --
.../operator/math/BeamSqlExpExpression.java | 41 --
.../operator/math/BeamSqlFloorExpression.java | 46 --
.../operator/math/BeamSqlLnExpression.java | 41 --
.../operator/math/BeamSqlLogExpression.java | 41 --
.../math/BeamSqlMathBinaryExpression.java | 64 ---
.../math/BeamSqlMathUnaryExpression.java | 58 ---
.../operator/math/BeamSqlPiExpression.java | 42 --
.../operator/math/BeamSqlPowerExpression.java | 45 --
.../operator/math/BeamSqlRadiansExpression.java | 41 --
.../operator/math/BeamSqlRandExpression.java | 54 ---
.../math/BeamSqlRandIntegerExpression.java | 58 ---
.../operator/math/BeamSqlRoundExpression.java | 108 -----
.../operator/math/BeamSqlSignExpression.java | 72 ---
.../operator/math/BeamSqlSinExpression.java | 41 --
.../operator/math/BeamSqlTanExpression.java | 41 --
.../math/BeamSqlTruncateExpression.java | 76 ----
.../interpreter/operator/math/package-info.java | 22 -
.../sql/interpreter/operator/package-info.java | 22 -
.../string/BeamSqlCharLengthExpression.java | 40 --
.../string/BeamSqlConcatExpression.java | 63 ---
.../string/BeamSqlInitCapExpression.java | 56 ---
.../operator/string/BeamSqlLowerExpression.java | 40 --
.../string/BeamSqlOverlayExpression.java | 77 ----
.../string/BeamSqlPositionExpression.java | 73 ---
.../string/BeamSqlStringUnaryExpression.java | 45 --
.../string/BeamSqlSubstringExpression.java | 83 ----
.../operator/string/BeamSqlTrimExpression.java | 101 -----
.../operator/string/BeamSqlUpperExpression.java | 40 --
.../operator/string/package-info.java | 22 -
.../beam/dsls/sql/interpreter/package-info.java | 22 -
.../org/apache/beam/dsls/sql/package-info.java | 22 -
.../beam/dsls/sql/planner/BeamQueryPlanner.java | 167 -------
.../dsls/sql/planner/BeamRelDataTypeSystem.java | 40 --
.../beam/dsls/sql/planner/BeamRuleSets.java | 75 ---
.../beam/dsls/sql/planner/package-info.java | 24 -
.../beam/dsls/sql/rel/BeamAggregationRel.java | 182 --------
.../apache/beam/dsls/sql/rel/BeamFilterRel.java | 70 ---
.../apache/beam/dsls/sql/rel/BeamIOSinkRel.java | 75 ---
.../beam/dsls/sql/rel/BeamIOSourceRel.java | 63 ---
.../beam/dsls/sql/rel/BeamIntersectRel.java | 58 ---
.../apache/beam/dsls/sql/rel/BeamJoinRel.java | 302 -------------
.../dsls/sql/rel/BeamLogicalConvention.java | 72 ---
.../apache/beam/dsls/sql/rel/BeamMinusRel.java | 56 ---
.../beam/dsls/sql/rel/BeamProjectRel.java | 81 ----
.../apache/beam/dsls/sql/rel/BeamRelNode.java | 38 --
.../dsls/sql/rel/BeamSetOperatorRelBase.java | 98 ----
.../apache/beam/dsls/sql/rel/BeamSortRel.java | 247 ----------
.../beam/dsls/sql/rel/BeamSqlRelUtils.java | 73 ---
.../apache/beam/dsls/sql/rel/BeamUnionRel.java | 88 ----
.../apache/beam/dsls/sql/rel/BeamValuesRel.java | 79 ----
.../apache/beam/dsls/sql/rel/package-info.java | 23 -
.../beam/dsls/sql/rule/BeamAggregationRule.java | 162 -------
.../beam/dsls/sql/rule/BeamFilterRule.java | 49 --
.../beam/dsls/sql/rule/BeamIOSinkRule.java | 82 ----
.../beam/dsls/sql/rule/BeamIOSourceRule.java | 49 --
.../beam/dsls/sql/rule/BeamIntersectRule.java | 51 ---
.../apache/beam/dsls/sql/rule/BeamJoinRule.java | 53 ---
.../beam/dsls/sql/rule/BeamMinusRule.java | 51 ---
.../beam/dsls/sql/rule/BeamProjectRule.java | 50 --
.../apache/beam/dsls/sql/rule/BeamSortRule.java | 52 ---
.../beam/dsls/sql/rule/BeamUnionRule.java | 50 --
.../beam/dsls/sql/rule/BeamValuesRule.java | 48 --
.../apache/beam/dsls/sql/rule/package-info.java | 23 -
.../beam/dsls/sql/schema/BaseBeamTable.java | 34 --
.../apache/beam/dsls/sql/schema/BeamIOType.java | 28 --
.../dsls/sql/schema/BeamPCollectionTable.java | 61 ---
.../apache/beam/dsls/sql/schema/BeamSqlRow.java | 314 -------------
.../beam/dsls/sql/schema/BeamSqlRowCoder.java | 185 --------
.../beam/dsls/sql/schema/BeamSqlRowType.java | 40 --
.../beam/dsls/sql/schema/BeamSqlTable.java | 52 ---
.../beam/dsls/sql/schema/BeamSqlUdaf.java | 72 ---
.../apache/beam/dsls/sql/schema/BeamSqlUdf.java | 41 --
.../beam/dsls/sql/schema/BeamTableUtils.java | 122 -----
.../sql/schema/kafka/BeamKafkaCSVTable.java | 111 -----
.../dsls/sql/schema/kafka/BeamKafkaTable.java | 109 -----
.../dsls/sql/schema/kafka/package-info.java | 22 -
.../beam/dsls/sql/schema/package-info.java | 22 -
.../dsls/sql/schema/text/BeamTextCSVTable.java | 70 ---
.../schema/text/BeamTextCSVTableIOReader.java | 59 ---
.../schema/text/BeamTextCSVTableIOWriter.java | 59 ---
.../dsls/sql/schema/text/BeamTextTable.java | 42 --
.../beam/dsls/sql/schema/text/package-info.java | 22 -
.../transform/BeamAggregationTransforms.java | 300 ------------
.../sql/transform/BeamBuiltinAggregations.java | 412 -----------------
.../dsls/sql/transform/BeamJoinTransforms.java | 166 -------
.../transform/BeamSetOperatorsTransforms.java | 112 -----
.../dsls/sql/transform/BeamSqlFilterFn.java | 62 ---
.../sql/transform/BeamSqlOutputToConsoleFn.java | 41 --
.../dsls/sql/transform/BeamSqlProjectFn.java | 72 ---
.../beam/dsls/sql/transform/package-info.java | 22 -
.../beam/dsls/sql/utils/CalciteUtils.java | 113 -----
.../beam/dsls/sql/utils/package-info.java | 22 -
dsls/sql/src/main/resources/log4j.properties | 23 -
.../beam/dsls/sql/BeamSqlApiSurfaceTest.java | 59 ---
.../dsls/sql/BeamSqlDslAggregationTest.java | 380 ----------------
.../apache/beam/dsls/sql/BeamSqlDslBase.java | 170 -------
.../beam/dsls/sql/BeamSqlDslFilterTest.java | 155 -------
.../beam/dsls/sql/BeamSqlDslJoinTest.java | 191 --------
.../beam/dsls/sql/BeamSqlDslProjectTest.java | 238 ----------
.../beam/dsls/sql/BeamSqlDslUdfUdafTest.java | 138 ------
.../org/apache/beam/dsls/sql/TestUtils.java | 195 --------
...amSqlArithmeticOperatorsIntegrationTest.java | 165 -------
...mSqlBuiltinFunctionsIntegrationTestBase.java | 169 -------
...amSqlComparisonOperatorsIntegrationTest.java | 330 --------------
...mSqlConditionalFunctionsIntegrationTest.java | 60 ---
.../BeamSqlDateFunctionsIntegrationTest.java | 88 ----
.../BeamSqlLogicalFunctionsIntegrationTest.java | 43 --
.../BeamSqlMathFunctionsIntegrationTest.java | 351 --------------
.../BeamSqlStringFunctionsIntegrationTest.java | 51 ---
.../sql/interpreter/BeamSqlFnExecutorTest.java | 416 -----------------
.../interpreter/BeamSqlFnExecutorTestBase.java | 92 ----
.../operator/BeamNullExperssionTest.java | 55 ---
.../operator/BeamSqlAndOrExpressionTest.java | 62 ---
.../operator/BeamSqlCaseExpressionTest.java | 94 ----
.../operator/BeamSqlCastExpressionTest.java | 126 ------
.../operator/BeamSqlCompareExpressionTest.java | 115 -----
.../operator/BeamSqlInputRefExpressionTest.java | 57 ---
.../operator/BeamSqlPrimitiveTest.java | 59 ---
.../BeamSqlReinterpretExpressionTest.java | 77 ----
.../operator/BeamSqlUdfExpressionTest.java | 51 ---
.../BeamSqlArithmeticExpressionTest.java | 237 ----------
.../date/BeamSqlCurrentDateExpressionTest.java | 35 --
.../date/BeamSqlCurrentTimeExpressionTest.java | 40 --
.../BeamSqlCurrentTimestampExpressionTest.java | 40 --
.../date/BeamSqlDateCeilExpressionTest.java | 49 --
.../date/BeamSqlDateExpressionTestBase.java | 52 ---
.../date/BeamSqlDateFloorExpressionTest.java | 50 --
.../date/BeamSqlExtractExpressionTest.java | 96 ----
.../logical/BeamSqlNotExpressionTest.java | 48 --
.../math/BeamSqlMathBinaryExpressionTest.java | 203 ---------
.../math/BeamSqlMathUnaryExpressionTest.java | 310 -------------
.../string/BeamSqlCharLengthExpressionTest.java | 45 --
.../string/BeamSqlConcatExpressionTest.java | 67 ---
.../string/BeamSqlInitCapExpressionTest.java | 55 ---
.../string/BeamSqlLowerExpressionTest.java | 45 --
.../string/BeamSqlOverlayExpressionTest.java | 88 ----
.../string/BeamSqlPositionExpressionTest.java | 85 ----
.../BeamSqlStringUnaryExpressionTest.java | 53 ---
.../string/BeamSqlSubstringExpressionTest.java | 102 -----
.../string/BeamSqlTrimExpressionTest.java | 103 -----
.../string/BeamSqlUpperExpressionTest.java | 45 --
.../beam/dsls/sql/mock/MockedBoundedTable.java | 134 ------
.../apache/beam/dsls/sql/mock/MockedTable.java | 42 --
.../dsls/sql/mock/MockedUnboundedTable.java | 114 -----
.../beam/dsls/sql/rel/BeamIntersectRelTest.java | 119 -----
.../rel/BeamJoinRelBoundedVsBoundedTest.java | 204 ---------
.../rel/BeamJoinRelUnboundedVsBoundedTest.java | 241 ----------
.../BeamJoinRelUnboundedVsUnboundedTest.java | 219 ---------
.../beam/dsls/sql/rel/BeamMinusRelTest.java | 118 -----
.../sql/rel/BeamSetOperatorRelBaseTest.java | 106 -----
.../beam/dsls/sql/rel/BeamSortRelTest.java | 237 ----------
.../beam/dsls/sql/rel/BeamUnionRelTest.java | 104 -----
.../beam/dsls/sql/rel/BeamValuesRelTest.java | 105 -----
.../org/apache/beam/dsls/sql/rel/CheckSize.java | 41 --
.../dsls/sql/schema/BeamSqlRowCoderTest.java | 83 ----
.../sql/schema/kafka/BeamKafkaCSVTableTest.java | 111 -----
.../sql/schema/text/BeamTextCSVTableTest.java | 176 -------
.../transform/BeamAggregationTransformTest.java | 453 -------------------
.../schema/transform/BeamTransformBaseTest.java | 97 ----
pom.xml | 1 -
sdks/java/extensions/pom.xml | 1 +
sdks/java/extensions/sql/pom.xml | 226 +++++++++
.../apache/beam/sdk/extensions/sql/BeamSql.java | 244 ++++++++++
.../beam/sdk/extensions/sql/BeamSqlCli.java | 65 +++
.../beam/sdk/extensions/sql/BeamSqlEnv.java | 119 +++++
.../extensions/sql/example/BeamSqlExample.java | 97 ++++
.../extensions/sql/example/package-info.java | 23 +
.../interpreter/BeamSqlExpressionExecutor.java | 43 ++
.../sql/impl/interpreter/BeamSqlFnExecutor.java | 442 ++++++++++++++++++
.../operator/BeamSqlCaseExpression.java | 63 +++
.../operator/BeamSqlCastExpression.java | 131 ++++++
.../interpreter/operator/BeamSqlExpression.java | 78 ++++
.../operator/BeamSqlInputRefExpression.java | 43 ++
.../interpreter/operator/BeamSqlPrimitive.java | 152 +++++++
.../operator/BeamSqlReinterpretExpression.java | 54 +++
.../operator/BeamSqlUdfExpression.java | 86 ++++
.../operator/BeamSqlWindowEndExpression.java | 42 ++
.../operator/BeamSqlWindowExpression.java | 50 ++
.../operator/BeamSqlWindowStartExpression.java | 43 ++
.../arithmetic/BeamSqlArithmeticExpression.java | 122 +++++
.../arithmetic/BeamSqlDivideExpression.java | 37 ++
.../arithmetic/BeamSqlMinusExpression.java | 36 ++
.../arithmetic/BeamSqlModExpression.java | 36 ++
.../arithmetic/BeamSqlMultiplyExpression.java | 36 ++
.../arithmetic/BeamSqlPlusExpression.java | 36 ++
.../operator/arithmetic/package-info.java | 22 +
.../comparison/BeamSqlCompareExpression.java | 96 ++++
.../comparison/BeamSqlEqualsExpression.java | 49 ++
.../BeamSqlGreaterThanExpression.java | 49 ++
.../BeamSqlGreaterThanOrEqualsExpression.java | 49 ++
.../comparison/BeamSqlIsNotNullExpression.java | 53 +++
.../comparison/BeamSqlIsNullExpression.java | 53 +++
.../comparison/BeamSqlLessThanExpression.java | 49 ++
.../BeamSqlLessThanOrEqualsExpression.java | 49 ++
.../comparison/BeamSqlNotEqualsExpression.java | 49 ++
.../operator/comparison/package-info.java | 22 +
.../date/BeamSqlCurrentDateExpression.java | 44 ++
.../date/BeamSqlCurrentTimeExpression.java | 52 +++
.../date/BeamSqlCurrentTimestampExpression.java | 48 ++
.../date/BeamSqlDateCeilExpression.java | 54 +++
.../date/BeamSqlDateFloorExpression.java | 54 +++
.../operator/date/BeamSqlExtractExpression.java | 101 +++++
.../interpreter/operator/date/package-info.java | 22 +
.../operator/logical/BeamSqlAndExpression.java | 47 ++
.../logical/BeamSqlLogicalExpression.java | 46 ++
.../operator/logical/BeamSqlNotExpression.java | 53 +++
.../operator/logical/BeamSqlOrExpression.java | 47 ++
.../operator/logical/package-info.java | 22 +
.../operator/math/BeamSqlAbsExpression.java | 74 +++
.../operator/math/BeamSqlAcosExpression.java | 40 ++
.../operator/math/BeamSqlAsinExpression.java | 40 ++
.../operator/math/BeamSqlAtan2Expression.java | 42 ++
.../operator/math/BeamSqlAtanExpression.java | 40 ++
.../operator/math/BeamSqlCeilExpression.java | 45 ++
.../operator/math/BeamSqlCosExpression.java | 40 ++
.../operator/math/BeamSqlCotExpression.java | 40 ++
.../operator/math/BeamSqlDegreesExpression.java | 40 ++
.../operator/math/BeamSqlExpExpression.java | 40 ++
.../operator/math/BeamSqlFloorExpression.java | 45 ++
.../operator/math/BeamSqlLnExpression.java | 40 ++
.../operator/math/BeamSqlLogExpression.java | 40 ++
.../math/BeamSqlMathBinaryExpression.java | 63 +++
.../math/BeamSqlMathUnaryExpression.java | 58 +++
.../operator/math/BeamSqlPiExpression.java | 42 ++
.../operator/math/BeamSqlPowerExpression.java | 44 ++
.../operator/math/BeamSqlRadiansExpression.java | 40 ++
.../operator/math/BeamSqlRandExpression.java | 54 +++
.../math/BeamSqlRandIntegerExpression.java | 58 +++
.../operator/math/BeamSqlRoundExpression.java | 107 +++++
.../operator/math/BeamSqlSignExpression.java | 72 +++
.../operator/math/BeamSqlSinExpression.java | 40 ++
.../operator/math/BeamSqlTanExpression.java | 40 ++
.../math/BeamSqlTruncateExpression.java | 75 +++
.../interpreter/operator/math/package-info.java | 22 +
.../impl/interpreter/operator/package-info.java | 22 +
.../string/BeamSqlCharLengthExpression.java | 39 ++
.../string/BeamSqlConcatExpression.java | 62 +++
.../string/BeamSqlInitCapExpression.java | 55 +++
.../operator/string/BeamSqlLowerExpression.java | 39 ++
.../string/BeamSqlOverlayExpression.java | 76 ++++
.../string/BeamSqlPositionExpression.java | 72 +++
.../string/BeamSqlStringUnaryExpression.java | 44 ++
.../string/BeamSqlSubstringExpression.java | 82 ++++
.../operator/string/BeamSqlTrimExpression.java | 101 +++++
.../operator/string/BeamSqlUpperExpression.java | 39 ++
.../operator/string/package-info.java | 22 +
.../sql/impl/interpreter/package-info.java | 22 +
.../sql/impl/planner/BeamQueryPlanner.java | 167 +++++++
.../sql/impl/planner/BeamRelDataTypeSystem.java | 40 ++
.../sql/impl/planner/BeamRuleSets.java | 75 +++
.../sql/impl/planner/package-info.java | 24 +
.../sql/impl/rel/BeamAggregationRel.java | 182 ++++++++
.../extensions/sql/impl/rel/BeamFilterRel.java | 70 +++
.../extensions/sql/impl/rel/BeamIOSinkRel.java | 75 +++
.../sql/impl/rel/BeamIOSourceRel.java | 63 +++
.../sql/impl/rel/BeamIntersectRel.java | 58 +++
.../extensions/sql/impl/rel/BeamJoinRel.java | 302 +++++++++++++
.../sql/impl/rel/BeamLogicalConvention.java | 72 +++
.../extensions/sql/impl/rel/BeamMinusRel.java | 56 +++
.../extensions/sql/impl/rel/BeamProjectRel.java | 81 ++++
.../extensions/sql/impl/rel/BeamRelNode.java | 38 ++
.../sql/impl/rel/BeamSetOperatorRelBase.java | 98 ++++
.../extensions/sql/impl/rel/BeamSortRel.java | 247 ++++++++++
.../sql/impl/rel/BeamSqlRelUtils.java | 72 +++
.../extensions/sql/impl/rel/BeamUnionRel.java | 88 ++++
.../extensions/sql/impl/rel/BeamValuesRel.java | 79 ++++
.../extensions/sql/impl/rel/package-info.java | 23 +
.../sql/impl/rule/BeamAggregationRule.java | 162 +++++++
.../sql/impl/rule/BeamFilterRule.java | 49 ++
.../sql/impl/rule/BeamIOSinkRule.java | 81 ++++
.../sql/impl/rule/BeamIOSourceRule.java | 49 ++
.../sql/impl/rule/BeamIntersectRule.java | 50 ++
.../extensions/sql/impl/rule/BeamJoinRule.java | 53 +++
.../extensions/sql/impl/rule/BeamMinusRule.java | 50 ++
.../sql/impl/rule/BeamProjectRule.java | 50 ++
.../extensions/sql/impl/rule/BeamSortRule.java | 51 +++
.../extensions/sql/impl/rule/BeamUnionRule.java | 50 ++
.../sql/impl/rule/BeamValuesRule.java | 48 ++
.../extensions/sql/impl/rule/package-info.java | 23 +
.../transform/BeamAggregationTransforms.java | 300 ++++++++++++
.../impl/transform/BeamBuiltinAggregations.java | 412 +++++++++++++++++
.../sql/impl/transform/BeamJoinTransforms.java | 166 +++++++
.../transform/BeamSetOperatorsTransforms.java | 111 +++++
.../sql/impl/transform/BeamSqlFilterFn.java | 62 +++
.../transform/BeamSqlOutputToConsoleFn.java | 41 ++
.../sql/impl/transform/BeamSqlProjectFn.java | 72 +++
.../sql/impl/transform/package-info.java | 22 +
.../extensions/sql/impl/utils/CalciteUtils.java | 113 +++++
.../extensions/sql/impl/utils/package-info.java | 22 +
.../beam/sdk/extensions/sql/package-info.java | 22 +
.../extensions/sql/schema/BaseBeamTable.java | 34 ++
.../sdk/extensions/sql/schema/BeamIOType.java | 28 ++
.../sql/schema/BeamPCollectionTable.java | 61 +++
.../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 | 52 +++
.../sdk/extensions/sql/schema/BeamSqlUdaf.java | 72 +++
.../sdk/extensions/sql/schema/BeamSqlUdf.java | 41 ++
.../extensions/sql/schema/BeamTableUtils.java | 122 +++++
.../sql/schema/kafka/BeamKafkaCSVTable.java | 109 +++++
.../sql/schema/kafka/BeamKafkaTable.java | 109 +++++
.../sql/schema/kafka/package-info.java | 22 +
.../sdk/extensions/sql/schema/package-info.java | 22 +
.../sql/schema/text/BeamTextCSVTable.java | 70 +++
.../schema/text/BeamTextCSVTableIOReader.java | 58 +++
.../schema/text/BeamTextCSVTableIOWriter.java | 58 +++
.../sql/schema/text/BeamTextTable.java | 41 ++
.../sql/schema/text/package-info.java | 22 +
.../sql/src/main/resources/log4j.properties | 23 +
.../extensions/sql/BeamSqlApiSurfaceTest.java | 59 +++
.../sql/BeamSqlDslAggregationTest.java | 380 ++++++++++++++++
.../beam/sdk/extensions/sql/BeamSqlDslBase.java | 170 +++++++
.../extensions/sql/BeamSqlDslFilterTest.java | 155 +++++++
.../sdk/extensions/sql/BeamSqlDslJoinTest.java | 191 ++++++++
.../extensions/sql/BeamSqlDslProjectTest.java | 238 ++++++++++
.../extensions/sql/BeamSqlDslUdfUdafTest.java | 138 ++++++
.../beam/sdk/extensions/sql/TestUtils.java | 195 ++++++++
.../impl/interpreter/BeamSqlFnExecutorTest.java | 416 +++++++++++++++++
.../interpreter/BeamSqlFnExecutorTestBase.java | 92 ++++
.../operator/BeamNullExperssionTest.java | 55 +++
.../operator/BeamSqlAndOrExpressionTest.java | 61 +++
.../operator/BeamSqlCaseExpressionTest.java | 93 ++++
.../operator/BeamSqlCastExpressionTest.java | 125 +++++
.../operator/BeamSqlCompareExpressionTest.java | 115 +++++
.../operator/BeamSqlInputRefExpressionTest.java | 57 +++
.../operator/BeamSqlPrimitiveTest.java | 59 +++
.../BeamSqlReinterpretExpressionTest.java | 75 +++
.../operator/BeamSqlUdfExpressionTest.java | 51 +++
.../BeamSqlArithmeticExpressionTest.java | 237 ++++++++++
.../date/BeamSqlCurrentDateExpressionTest.java | 38 ++
.../date/BeamSqlCurrentTimeExpressionTest.java | 39 ++
.../BeamSqlCurrentTimestampExpressionTest.java | 39 ++
.../date/BeamSqlDateCeilExpressionTest.java | 50 ++
.../date/BeamSqlDateExpressionTestBase.java | 51 +++
.../date/BeamSqlDateFloorExpressionTest.java | 49 ++
.../date/BeamSqlExtractExpressionTest.java | 103 +++++
.../logical/BeamSqlNotExpressionTest.java | 47 ++
.../math/BeamSqlMathBinaryExpressionTest.java | 201 ++++++++
.../math/BeamSqlMathUnaryExpressionTest.java | 309 +++++++++++++
.../string/BeamSqlCharLengthExpressionTest.java | 44 ++
.../string/BeamSqlConcatExpressionTest.java | 66 +++
.../string/BeamSqlInitCapExpressionTest.java | 54 +++
.../string/BeamSqlLowerExpressionTest.java | 44 ++
.../string/BeamSqlOverlayExpressionTest.java | 87 ++++
.../string/BeamSqlPositionExpressionTest.java | 84 ++++
.../BeamSqlStringUnaryExpressionTest.java | 52 +++
.../string/BeamSqlSubstringExpressionTest.java | 101 +++++
.../string/BeamSqlTrimExpressionTest.java | 103 +++++
.../string/BeamSqlUpperExpressionTest.java | 44 ++
.../sql/impl/rel/BeamIntersectRelTest.java | 119 +++++
.../rel/BeamJoinRelBoundedVsBoundedTest.java | 204 +++++++++
.../rel/BeamJoinRelUnboundedVsBoundedTest.java | 241 ++++++++++
.../BeamJoinRelUnboundedVsUnboundedTest.java | 219 +++++++++
.../sql/impl/rel/BeamMinusRelTest.java | 118 +++++
.../impl/rel/BeamSetOperatorRelBaseTest.java | 106 +++++
.../sql/impl/rel/BeamSortRelTest.java | 237 ++++++++++
.../sql/impl/rel/BeamUnionRelTest.java | 104 +++++
.../sql/impl/rel/BeamValuesRelTest.java | 105 +++++
.../sdk/extensions/sql/impl/rel/CheckSize.java | 41 ++
...amSqlArithmeticOperatorsIntegrationTest.java | 165 +++++++
...mSqlBuiltinFunctionsIntegrationTestBase.java | 169 +++++++
...amSqlComparisonOperatorsIntegrationTest.java | 330 ++++++++++++++
...mSqlConditionalFunctionsIntegrationTest.java | 60 +++
.../BeamSqlDateFunctionsIntegrationTest.java | 88 ++++
.../BeamSqlLogicalFunctionsIntegrationTest.java | 43 ++
.../BeamSqlMathFunctionsIntegrationTest.java | 351 ++++++++++++++
.../BeamSqlStringFunctionsIntegrationTest.java | 51 +++
.../extensions/sql/mock/MockedBoundedTable.java | 134 ++++++
.../sdk/extensions/sql/mock/MockedTable.java | 42 ++
.../sql/mock/MockedUnboundedTable.java | 112 +++++
.../sql/schema/BeamSqlRowCoderTest.java | 82 ++++
.../sql/schema/kafka/BeamKafkaCSVTableTest.java | 111 +++++
.../sql/schema/text/BeamTextCSVTableTest.java | 176 +++++++
.../transform/BeamAggregationTransformTest.java | 453 +++++++++++++++++++
.../schema/transform/BeamTransformBaseTest.java | 97 ++++
433 files changed, 19368 insertions(+), 19494 deletions(-)
----------------------------------------------------------------------