public static ReadChangeStream readChangeStream() {
    return ReadChangeStream.create();
  }
@Test
  public void testReadChangeStreamPassWithoutValidationDuringApply() {
    BigtableIO.ReadChangeStream readChangeStream =
        BigtableIO.readChangeStream()
            .withProjectId("project")
            .withInstanceId("instance")
            .withTableId("table")
            .withoutValidation();
    // No RunTime exception as seen in previous test with validation. Only error that the pipeline
    // is not ran.
    thrown.expect(PipelineRunMissingException.class);
    p.apply(readChangeStream);
  }