KafkaTableProvider extends InMemoryMetaTableProvider { @Override public String getTableType() { return "kafka"; }  @Override BeamSqlTable buildBeamSqlTable(Table table); @Override String getTableType();  }
@Test public void testGetTableType() throws Exception { assertEquals("kafka", provider.getTableType()); }