This is an automated email from the ASF dual-hosted git repository.
apilloud pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 063ee99 Merge pull request #9793 from robinyqiu/tmp
add 8fb53bf Created a MongoDbTable and a provider for it
add 36d6534 Merge pull request #10031: [BEAM-8427] [SQL] Create a table
and a table provider for MongoDB
No new revisions were added by this update.
Summary of changes:
sdks/java/extensions/sql/build.gradle | 3 +
.../sql/meta/provider/mongodb/MongoDbTable.java | 143 +++++++++++++++
.../MongoDbTableProvider.java} | 17 +-
.../sql/meta/provider/mongodb}/package-info.java | 4 +-
.../meta/provider/mongodb/MongoDbReadWriteIT.java | 197 +++++++++++++++++++++
.../provider/mongodb/MongoDbTableProviderTest.java | 118 ++++++++++++
.../meta/provider/mongodb/MongoDbTableTest.java | 105 +++++++++++
.../org/apache/beam/sdk/io/mongodb/MongoDbIO.java | 39 ++++
8 files changed, 616 insertions(+), 10 deletions(-)
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbTable.java
copy
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/{parquet/ParquetTableProvider.java
=> mongodb/MongoDbTableProvider.java} (79%)
copy
{runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph
=>
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb}/package-info.java
(90%)
create mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbReadWriteIT.java
create mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbTableProviderTest.java
create mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbTableTest.java
