beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ming...@apache.org
Subject [4/4] beam git commit: This closes #4041
Date Wed, 08 Nov 2017 17:33:48 GMT
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 <mingmxu@ebay.com>
Authored: Wed Nov 8 09:18:48 2017 -0800
Committer: mingmxu <mingmxu@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(-)
----------------------------------------------------------------------



Mime
View raw message