[BEAM-2740] This closes #3708
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a1cc5518 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a1cc5518 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a1cc5518 Branch: refs/heads/DSL_SQL Commit: a1cc5518e0c1cc83c33c3e2e87128fc59935a314 Parents: 9eec6a0 49aad92 Author: Tyler Akidau <[email protected]> Authored: Tue Aug 15 11:40:59 2017 -0700 Committer: Tyler Akidau <[email protected]> Committed: Tue Aug 15 11:40:59 2017 -0700 ---------------------------------------------------------------------- .../sdk/extensions/sql/BeamRecordSqlType.java | 185 ++++++++ .../apache/beam/sdk/extensions/sql/BeamSql.java | 113 ++--- .../beam/sdk/extensions/sql/BeamSqlCli.java | 65 --- .../beam/sdk/extensions/sql/BeamSqlEnv.java | 127 ------ .../sdk/extensions/sql/BeamSqlRecordHelper.java | 217 +++++++++ .../beam/sdk/extensions/sql/BeamSqlUdf.java | 41 ++ .../extensions/sql/example/BeamSqlExample.java | 2 +- .../sdk/extensions/sql/impl/BeamSqlCli.java | 65 +++ .../sdk/extensions/sql/impl/BeamSqlEnv.java | 135 ++++++ .../sdk/extensions/sql/impl/package-info.java | 22 + .../sql/impl/planner/BeamQueryPlanner.java | 9 +- .../sql/impl/rel/BeamAggregationRel.java | 4 +- .../extensions/sql/impl/rel/BeamFilterRel.java | 2 +- .../extensions/sql/impl/rel/BeamIOSinkRel.java | 6 +- .../sql/impl/rel/BeamIOSourceRel.java | 6 +- .../sql/impl/rel/BeamIntersectRel.java | 2 +- .../extensions/sql/impl/rel/BeamJoinRel.java | 4 +- .../extensions/sql/impl/rel/BeamMinusRel.java | 2 +- .../extensions/sql/impl/rel/BeamProjectRel.java | 2 +- .../extensions/sql/impl/rel/BeamRelNode.java | 5 +- .../sql/impl/rel/BeamSetOperatorRelBase.java | 2 +- .../extensions/sql/impl/rel/BeamSortRel.java | 4 +- .../extensions/sql/impl/rel/BeamUnionRel.java | 2 +- .../extensions/sql/impl/rel/BeamValuesRel.java | 6 +- .../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 | 4 +- .../sql/impl/transform/BeamJoinTransforms.java | 4 +- .../sql/impl/transform/BeamSqlProjectFn.java | 4 +- .../extensions/sql/impl/utils/CalciteUtils.java | 2 +- .../extensions/sql/schema/BaseBeamTable.java | 34 -- .../sdk/extensions/sql/schema/BeamIOType.java | 28 -- .../sql/schema/BeamPCollectionTable.java | 62 --- .../sql/schema/BeamRecordSqlType.java | 185 -------- .../sql/schema/BeamSqlRecordHelper.java | 217 --------- .../sdk/extensions/sql/schema/BeamSqlTable.java | 53 --- .../sdk/extensions/sql/schema/BeamSqlUdf.java | 41 -- .../extensions/sql/schema/BeamTableUtils.java | 117 ----- .../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 - .../extensions/sql/BeamSqlApiSurfaceTest.java | 12 +- .../sql/BeamSqlDslAggregationTest.java | 1 - .../beam/sdk/extensions/sql/BeamSqlDslBase.java | 1 - .../sdk/extensions/sql/BeamSqlDslJoinTest.java | 1 - .../extensions/sql/BeamSqlDslProjectTest.java | 1 - .../extensions/sql/BeamSqlDslUdfUdafTest.java | 2 - .../beam/sdk/extensions/sql/TestUtils.java | 1 - .../interpreter/BeamSqlFnExecutorTestBase.java | 2 +- .../extensions/sql/impl/rel/BaseRelTest.java | 34 ++ .../sql/impl/rel/BeamIntersectRelTest.java | 9 +- .../rel/BeamJoinRelBoundedVsBoundedTest.java | 23 +- .../rel/BeamJoinRelUnboundedVsBoundedTest.java | 25 +- .../BeamJoinRelUnboundedVsUnboundedTest.java | 19 +- .../sql/impl/rel/BeamMinusRelTest.java | 9 +- .../impl/rel/BeamSetOperatorRelBaseTest.java | 9 +- .../sql/impl/rel/BeamSortRelTest.java | 17 +- .../sql/impl/rel/BeamUnionRelTest.java | 9 +- .../sql/impl/rel/BeamValuesRelTest.java | 11 +- .../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 ++++ ...mSqlBuiltinFunctionsIntegrationTestBase.java | 2 +- ...amSqlComparisonOperatorsIntegrationTest.java | 2 +- .../extensions/sql/mock/MockedBoundedTable.java | 4 +- .../sdk/extensions/sql/mock/MockedTable.java | 4 +- .../sql/mock/MockedUnboundedTable.java | 4 +- .../sql/schema/BeamSqlRowCoderTest.java | 76 ---- .../sql/schema/kafka/BeamKafkaCSVTableTest.java | 107 ----- .../sql/schema/text/BeamTextCSVTableTest.java | 176 ------- .../transform/BeamAggregationTransformTest.java | 453 ------------------- .../schema/transform/BeamTransformBaseTest.java | 97 ---- 92 files changed, 2575 insertions(+), 2545 deletions(-) ----------------------------------------------------------------------
