InMemoryMetaStore implements MetaStore { @Override public BeamSqlTable buildBeamSqlTable(Table table) { TableProvider provider = providers.get(table.getType()); return provider.buildBeamSqlTable(table); }  @Override String getTableType(); @Override void createTable(Table table); @Override void dropTable(String tableName); @Override Map<String, Table> getTables(); @Override BeamSqlTable buildBeamSqlTable(Table table); @Override void registerProvider(TableProvider provider);  }
@Test public void testBuildBeamSqlTable() throws Exception { Table table = mockTable("hello"); store.createTable(table); BeamSqlTable actualSqlTable = store.buildBeamSqlTable(table); assertNotNull(actualSqlTable); assertEquals( Schema.builder() .addNullableField("id", Schema.FieldType.INT32) .addNullableField("name", Schema.FieldType.STRING) .build(), actualSqlTable.getSchema()); }