Class MongoDbTableProvider

java.lang.Object
org.apache.beam.sdk.extensions.sql.meta.provider.InMemoryMetaTableProvider
org.apache.beam.sdk.extensions.sql.meta.provider.mongodb.MongoDbTableProvider
All Implemented Interfaces:
TableProvider

@AutoService(TableProvider.class) public class MongoDbTableProvider extends InMemoryMetaTableProvider
TableProvider for MongoDbTable.

A sample of MongoDb table is:


 CREATE TABLE ORDERS(
   name VARCHAR,
   favorite_color VARCHAR,
   favorite_numbers ARRAY<INTEGER>
 )
 TYPE 'mongodb'
 LOCATION 'mongodb://username:password@localhost:27017/database/collection'
 
  • Constructor Details

    • MongoDbTableProvider

      public MongoDbTableProvider()
  • Method Details

    • getTableType

      public String getTableType()
      Description copied from interface: TableProvider
      Gets the table type this provider handles.
    • buildBeamSqlTable

      public BeamSqlTable buildBeamSqlTable(Table table)
      Description copied from interface: TableProvider
      Build a BeamSqlTable using the given table meta info.