beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ming...@apache.org
Subject [66/66] [abbrv] beam git commit: This closes #3782
Date Mon, 11 Sep 2017 20:19:49 GMT
This closes #3782


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

Branch: refs/heads/master
Commit: 39e66e953b0f8e16435acb038cad364acf2b3a57
Parents: d60b29f aa12fb7
Author: mingmxu <mingmxu@ebay.com>
Authored: Mon Sep 11 10:58:01 2017 -0700
Committer: mingmxu <mingmxu@ebay.com>
Committed: Mon Sep 11 10:58:01 2017 -0700

----------------------------------------------------------------------
 pom.xml                                         |  14 +
 .../apache/beam/sdk/coders/BeamRecordCoder.java | 111 ++++
 .../org/apache/beam/sdk/values/BeamRecord.java  | 319 +++++++++++
 .../apache/beam/sdk/values/BeamRecordType.java  |  96 ++++
 sdks/java/extensions/pom.xml                    |   1 +
 sdks/java/extensions/sql/pom.xml                | 226 ++++++++
 .../sdk/extensions/sql/BeamRecordSqlType.java   | 186 +++++++
 .../apache/beam/sdk/extensions/sql/BeamSql.java | 250 +++++++++
 .../sdk/extensions/sql/BeamSqlRecordHelper.java | 217 ++++++++
 .../beam/sdk/extensions/sql/BeamSqlUdf.java     |  43 ++
 .../extensions/sql/example/BeamSqlExample.java  |  99 ++++
 .../extensions/sql/example/package-info.java    |  23 +
 .../sdk/extensions/sql/impl/BeamSqlCli.java     |  65 +++
 .../sdk/extensions/sql/impl/BeamSqlEnv.java     | 135 +++++
 .../interpreter/BeamSqlExpressionExecutor.java  |  44 ++
 .../sql/impl/interpreter/BeamSqlFnExecutor.java | 443 +++++++++++++++
 .../operator/BeamSqlCaseExpression.java         |  64 +++
 .../operator/BeamSqlCastExpression.java         | 132 +++++
 .../interpreter/operator/BeamSqlExpression.java |  79 +++
 .../operator/BeamSqlInputRefExpression.java     |  48 ++
 .../interpreter/operator/BeamSqlPrimitive.java  | 153 ++++++
 .../operator/BeamSqlReinterpretExpression.java  |  55 ++
 .../operator/BeamSqlUdfExpression.java          |  92 ++++
 .../operator/BeamSqlWindowEndExpression.java    |  48 ++
 .../operator/BeamSqlWindowExpression.java       |  51 ++
 .../operator/BeamSqlWindowStartExpression.java  |  49 ++
 .../sql/impl/interpreter/operator/UdafImpl.java |  87 +++
 .../arithmetic/BeamSqlArithmeticExpression.java | 124 +++++
 .../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    |  97 ++++
 .../comparison/BeamSqlEqualsExpression.java     |  49 ++
 .../BeamSqlGreaterThanExpression.java           |  49 ++
 .../BeamSqlGreaterThanOrEqualsExpression.java   |  49 ++
 .../comparison/BeamSqlIsNotNullExpression.java  |  54 ++
 .../comparison/BeamSqlIsNullExpression.java     |  54 ++
 .../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 | 102 ++++
 .../interpreter/operator/date/package-info.java |  22 +
 .../operator/logical/BeamSqlAndExpression.java  |  48 ++
 .../logical/BeamSqlLogicalExpression.java       |  46 ++
 .../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    |  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       |  65 +++
 .../math/BeamSqlMathUnaryExpression.java        |  60 ++
 .../operator/math/BeamSqlPiExpression.java      |  43 ++
 .../operator/math/BeamSqlPowerExpression.java   |  44 ++
 .../operator/math/BeamSqlRadiansExpression.java |  40 ++
 .../operator/math/BeamSqlRandExpression.java    |  55 ++
 .../math/BeamSqlRandIntegerExpression.java      |  59 ++
 .../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     |  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    |  44 ++
 .../string/BeamSqlSubstringExpression.java      |  83 +++
 .../operator/string/BeamSqlTrimExpression.java  | 102 ++++
 .../operator/string/BeamSqlUpperExpression.java |  40 ++
 .../operator/string/package-info.java           |  22 +
 .../sql/impl/interpreter/package-info.java      |  22 +
 .../sdk/extensions/sql/impl/package-info.java   |  22 +
 .../sql/impl/planner/BeamQueryPlanner.java      | 168 ++++++
 .../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  |  69 +++
 .../extensions/sql/impl/rel/BeamIOSinkRel.java  |  75 +++
 .../sql/impl/rel/BeamIOSourceRel.java           |  62 +++
 .../sql/impl/rel/BeamIntersectRel.java          |  58 ++
 .../extensions/sql/impl/rel/BeamJoinRel.java    | 298 ++++++++++
 .../sql/impl/rel/BeamLogicalConvention.java     |  72 +++
 .../extensions/sql/impl/rel/BeamMinusRel.java   |  56 ++
 .../extensions/sql/impl/rel/BeamProjectRel.java |  80 +++
 .../extensions/sql/impl/rel/BeamRelNode.java    |  39 ++
 .../sql/impl/rel/BeamSetOperatorRelBase.java    |  98 ++++
 .../extensions/sql/impl/rel/BeamSortRel.java    | 234 ++++++++
 .../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 +
 .../sql/impl/schema/BaseBeamTable.java          |  35 ++
 .../extensions/sql/impl/schema/BeamIOType.java  |  28 +
 .../sql/impl/schema/BeamPCollectionTable.java   |  63 +++
 .../sql/impl/schema/BeamSqlTable.java           |  54 ++
 .../sql/impl/schema/BeamTableUtils.java         | 118 ++++
 .../impl/schema/kafka/BeamKafkaCSVTable.java    | 109 ++++
 .../sql/impl/schema/kafka/BeamKafkaTable.java   | 109 ++++
 .../sql/impl/schema/kafka/package-info.java     |  22 +
 .../sql/impl/schema/package-info.java           |  22 +
 .../sql/impl/schema/text/BeamTextCSVTable.java  |  70 +++
 .../schema/text/BeamTextCSVTableIOReader.java   |  58 ++
 .../schema/text/BeamTextCSVTableIOWriter.java   |  58 ++
 .../sql/impl/schema/text/BeamTextTable.java     |  41 ++
 .../sql/impl/schema/text/package-info.java      |  22 +
 .../transform/BeamAggregationTransforms.java    | 311 +++++++++++
 .../impl/transform/BeamBuiltinAggregations.java | 549 +++++++++++++++++++
 .../sql/impl/transform/BeamJoinTransforms.java  | 161 ++++++
 .../transform/BeamSetOperatorsTransforms.java   | 111 ++++
 .../sql/impl/transform/BeamSqlFilterFn.java     |  63 +++
 .../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 +
 .../sql/src/main/resources/log4j.properties     |  23 +
 .../extensions/sql/BeamSqlApiSurfaceTest.java   |  57 ++
 .../sql/BeamSqlDslAggregationTest.java          | 400 ++++++++++++++
 .../beam/sdk/extensions/sql/BeamSqlDslBase.java | 136 +++++
 .../extensions/sql/BeamSqlDslFilterTest.java    | 155 ++++++
 .../sdk/extensions/sql/BeamSqlDslJoinTest.java  | 188 +++++++
 .../extensions/sql/BeamSqlDslProjectTest.java   | 227 ++++++++
 .../extensions/sql/BeamSqlDslUdfUdafTest.java   | 139 +++++
 .../beam/sdk/extensions/sql/TestUtils.java      | 190 +++++++
 .../impl/interpreter/BeamSqlFnExecutorTest.java | 416 ++++++++++++++
 .../interpreter/BeamSqlFnExecutorTestBase.java  |  88 +++
 .../operator/BeamNullExperssionTest.java        |  55 ++
 .../operator/BeamSqlAndOrExpressionTest.java    |  61 +++
 .../operator/BeamSqlCaseExpressionTest.java     |  93 ++++
 .../operator/BeamSqlCastExpressionTest.java     | 129 +++++
 .../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   | 215 ++++++++
 .../math/BeamSqlMathUnaryExpressionTest.java    | 312 +++++++++++
 .../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 ++
 .../extensions/sql/impl/rel/BaseRelTest.java    |  34 ++
 .../sql/impl/rel/BeamIntersectRelTest.java      | 118 ++++
 .../rel/BeamJoinRelBoundedVsBoundedTest.java    | 203 +++++++
 .../rel/BeamJoinRelUnboundedVsBoundedTest.java  | 240 ++++++++
 .../BeamJoinRelUnboundedVsUnboundedTest.java    | 218 ++++++++
 .../sql/impl/rel/BeamMinusRelTest.java          | 117 ++++
 .../impl/rel/BeamSetOperatorRelBaseTest.java    | 105 ++++
 .../sql/impl/rel/BeamSortRelTest.java           | 236 ++++++++
 .../sql/impl/rel/BeamUnionRelTest.java          | 103 ++++
 .../sql/impl/rel/BeamValuesRelTest.java         | 104 ++++
 .../sdk/extensions/sql/impl/rel/CheckSize.java  |  41 ++
 .../sql/impl/schema/BeamSqlRowCoderTest.java    |  77 +++
 .../schema/kafka/BeamKafkaCSVTableTest.java     | 107 ++++
 .../impl/schema/text/BeamTextCSVTableTest.java  | 176 ++++++
 .../transform/BeamAggregationTransformTest.java | 453 +++++++++++++++
 .../schema/transform/BeamTransformBaseTest.java |  97 ++++
 ...amSqlArithmeticOperatorsIntegrationTest.java | 165 ++++++
 ...mSqlBuiltinFunctionsIntegrationTestBase.java | 168 ++++++
 ...amSqlComparisonOperatorsIntegrationTest.java | 329 +++++++++++
 ...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          | 110 ++++
 sdks/java/io/kafka/pom.xml                      |   5 -
 222 files changed, 20018 insertions(+), 5 deletions(-)
----------------------------------------------------------------------



Mime
View raw message