public static ReadChangeStream readChangeStream() {
    return ReadChangeStream.create();
  }
@Test
  public void testReadChangeStreamValidationFailsDuringApply() {
    BigtableIO.ReadChangeStream readChangeStream =
        BigtableIO.readChangeStream()
            .withProjectId("project")
            .withInstanceId("instance")
            .withTableId("table");
    // Validating table fails because resources cannot be found
    thrown.expect(RuntimeException.class);

    p.apply(readChangeStream);
  }