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/15 18:42:00 UTC
[5/5] beam git commit: [BEAM-2740] This closes #3708
[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 <ta...@apache.org>
Authored: Tue Aug 15 11:40:59 2017 -0700
Committer: Tyler Akidau <ta...@apache.org>
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(-)
----------------------------------------------------------------------