public static ReadChangeStream readChangeStream() {
    return ReadChangeStream.create();
  }
@Test
  public void testReadChangeStreamPassWithoutValidation() {
    BigtableIO.ReadChangeStream readChangeStream =
        BigtableIO.readChangeStream()
            .withProjectId("project")
            .withInstanceId("instance")
            .withTableId("table")
            .withoutValidation();
    // No error is thrown because we skip validation
    readChangeStream.validate(TestPipeline.testingPipelineOptions());
  }