You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by mi...@apache.org on 2017/11/08 17:33:48 UTC
[4/4] beam git commit: This closes #4041
This closes #4041
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/59877473
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/59877473
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/59877473
Branch: refs/heads/master
Commit: 598774738e7a1236cf30f70a584311cee52d1818
Parents: ae45bbd 208fc38
Author: mingmxu <mi...@ebay.com>
Authored: Wed Nov 8 09:18:48 2017 -0800
Committer: mingmxu <mi...@ebay.com>
Committed: Wed Nov 8 09:18:48 2017 -0800
----------------------------------------------------------------------
pom.xml | 2 +
.../src/main/resources/beam/findbugs-filter.xml | 7 +
sdks/java/extensions/sql/pom.xml | 148 ++++++++++++++-
.../extensions/sql/src/main/codegen/config.fmpp | 23 +++
.../sql/src/main/codegen/data/Parser.tdd | 75 ++++++++
.../sql/src/main/codegen/includes/license.ftl | 17 ++
.../src/main/codegen/includes/parserImpls.ftl | 89 +++++++++
.../beam/sdk/extensions/sql/BeamSqlCli.java | 115 ++++++++++++
.../beam/sdk/extensions/sql/BeamSqlTable.java | 54 ++++++
.../sdk/extensions/sql/impl/BeamSqlCli.java | 65 -------
.../sdk/extensions/sql/impl/BeamSqlEnv.java | 3 +-
.../sql/impl/parser/BeamSqlParser.java | 50 +++++
.../sql/impl/parser/ColumnConstraint.java | 42 +++++
.../sql/impl/parser/ColumnDefinition.java | 56 ++++++
.../extensions/sql/impl/parser/ParserUtils.java | 64 +++++++
.../sql/impl/parser/SqlCreateTable.java | 141 ++++++++++++++
.../sql/impl/parser/SqlDDLKeywords.java | 27 +++
.../extensions/sql/impl/parser/UnparseUtil.java | 59 ++++++
.../sql/impl/parser/package-info.java | 22 +++
.../sql/impl/planner/BeamQueryPlanner.java | 2 +-
.../extensions/sql/impl/rel/BeamIOSinkRel.java | 2 +-
.../sql/impl/rel/BeamIOSourceRel.java | 2 +-
.../sql/impl/schema/BaseBeamTable.java | 9 +-
.../sql/impl/schema/BeamSqlTable.java | 54 ------
.../sql/impl/schema/BeamTableUtils.java | 4 +-
.../impl/schema/kafka/BeamKafkaCSVTable.java | 109 -----------
.../sql/impl/schema/kafka/BeamKafkaTable.java | 109 -----------
.../sql/impl/schema/kafka/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 ---
.../beam/sdk/extensions/sql/meta/Column.java | 51 +++++
.../beam/sdk/extensions/sql/meta/Table.java | 69 +++++++
.../sdk/extensions/sql/meta/package-info.java | 22 +++
.../extensions/sql/meta/provider/MetaUtils.java | 40 ++++
.../sql/meta/provider/TableProvider.java | 61 ++++++
.../meta/provider/kafka/BeamKafkaCSVTable.java | 111 +++++++++++
.../sql/meta/provider/kafka/BeamKafkaTable.java | 115 ++++++++++++
.../meta/provider/kafka/KafkaTableProvider.java | 82 ++++++++
.../sql/meta/provider/kafka/package-info.java | 22 +++
.../sql/meta/provider/package-info.java | 22 +++
.../meta/provider/text/BeamTextCSVTable.java | 80 ++++++++
.../provider/text/BeamTextCSVTableIOReader.java | 59 ++++++
.../provider/text/BeamTextCSVTableIOWriter.java | 59 ++++++
.../sql/meta/provider/text/BeamTextTable.java | 41 ++++
.../meta/provider/text/TextTableProvider.java | 83 +++++++++
.../sql/meta/provider/text/package-info.java | 22 +++
.../sql/meta/store/InMemoryMetaStore.java | 113 +++++++++++
.../extensions/sql/meta/store/MetaStore.java | 56 ++++++
.../extensions/sql/meta/store/package-info.java | 22 +++
.../extensions/sql/BeamSqlApiSurfaceTest.java | 7 +-
.../beam/sdk/extensions/sql/BeamSqlCliTest.java | 75 ++++++++
.../beam/sdk/extensions/sql/TestUtils.java | 2 +-
.../sql/impl/parser/BeamSqlParserTest.java | 167 +++++++++++++++++
.../schema/kafka/BeamKafkaCSVTableTest.java | 107 -----------
.../impl/schema/text/BeamTextCSVTableTest.java | 176 ------------------
.../provider/kafka/BeamKafkaCSVTableTest.java | 107 +++++++++++
.../provider/kafka/KafkaTableProviderTest.java | 76 ++++++++
.../provider/text/BeamTextCSVTableTest.java | 176 ++++++++++++++++++
.../provider/text/TextTableProviderTest.java | 87 +++++++++
.../sql/meta/store/InMemoryMetaStoreTest.java | 185 +++++++++++++++++++
.../sql/mock/MockedUnboundedTable.java | 2 +-
64 files changed, 3011 insertions(+), 907 deletions(-)
----------------------------------------------------------------------