public static ReadChangeStream readChangeStream() {
    return ReadChangeStream.create();
  }
@Test
  public void testReadChangeStreamFailsValidation() {
    BigtableIO.ReadChangeStream readChangeStream =
        BigtableIO.readChangeStream()
            .withProjectId("project")
            .withInstanceId("instance")
            .withTableId("table");
    // Validating table fails because table does not exist.
    thrown.expect(IllegalArgumentException.class);
    readChangeStream.validate(TestPipeline.testingPipelineOptions());
  }