[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 <taki...@apache.org> Authored: Tue Aug 1 22:06:25 2017 -0700 Committer: Tyler Akidau <taki...@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(-) ----------------------------------------------------------------------