PubsubJsonTableProvider extends SchemaIOTableProviderWrapper { @Override public String getTableType() { return "pubsub"; }  @Override SchemaIOProvider getSchemaIOProvider(); @Override String getTableType();  }
@Test public void testTableTypePubsub() { PubsubJsonTableProvider provider = new PubsubJsonTableProvider(); assertEquals("pubsub", provider.getTableType()); }