public static BeamSqlEnvBuilder builder(TableProvider tableProvider) {
    return new BeamSqlEnvBuilder(tableProvider);
  }
@Test
  public void testPlannerClassNotFound() {
    exceptions.expect(RuntimeException.class);
    exceptions.expectCause(hasMessage(containsString("org.test.ClassNotFound")));

    TestTableProvider root = new TestTableProvider();
    BeamSqlEnv.builder(root)
        .setQueryPlannerClassName("org.test.ClassNotFound")
        .setPipelineOptions(PipelineOptionsFactory.create())
        .build();
  }