@Override
  public BeamSqlTable buildBeamSqlTable(Table table) {
    return new MongoDbTable(table);
  }
@Test
  public void testBuildBeamSqlTable() {
    Table table = fakeTable("TEST", "mongodb://localhost:27017/database/collection");
    BeamSqlTable sqlTable = provider.buildBeamSqlTable(table);

    assertNotNull(sqlTable);
    assertTrue(sqlTable instanceof MongoDbTable);

    MongoDbTable mongoTable = (MongoDbTable) sqlTable;
    assertEquals("mongodb://localhost:27017", mongoTable.dbUri);
    assertEquals("database", mongoTable.dbName);
    assertEquals("collection", mongoTable.dbCollection);
  }