---

rahulKQL · igorbernstein2 · commit f73b8f934465 · 2019-05-10T14:41:53.000-04:00
yaml --- r: 30769 b: refs/heads/autosynth-bigquerydatatransfer c: 2313bb5 h: refs/heads/master i: 30767: 2169d0f
diff --git a/[refs] b/[refs]
@@ -122,7 +122,7 @@ refs/tags/v0.68.0: 9cc799fcf68c82ab431d425fefa58ef615ce8e5b
 refs/tags/v0.69.0: 78f67a29e8b9c46ba01de566a2eae0fd1c03edea
 refs/heads/autosynth-asset: bdb45634a0fe8f7a510692b56b31f5312e25f453
 refs/heads/autosynth-automl: 22f9dd5b6f5df8dbfa7da0126864d565229519b2
-refs/heads/autosynth-bigquerydatatransfer: 06d6685b4c3eedcc4d513b47e6531859a08e07b2
+refs/heads/autosynth-bigquerydatatransfer: 2313bb545e4bb4ab74868033e5a11729f3cd00f7
 refs/heads/autosynth-bigquerystorage: d2c53da3b012e38c662e4df0738042435f19365f
 refs/heads/autosynth-bigtable: 9e5429f45cf9face9fed585d0233534993e36b58
 refs/heads/autosynth-bigtable-admin: 6379a2bc712f2736c83de0e009b4d26da4fa82ca
diff --git a/branches/autosynth-bigquerydatatransfer/google-cloud-clients/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/BigtableDataClient.java b/branches/autosynth-bigquerydatatransfer/google-cloud-clients/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/BigtableDataClient.java
@@ -513,9 +513,16 @@ public <RowT> UnaryCallable<Query, RowT> readRowCallable(RowAdapter<RowT> rowAda
    *          .range("[START KEY]", "[END KEY]")
    *          .filter(FILTERS.qualifier().regex("[COLUMN PREFIX].*"));
    *
-   *   // Iterator style
    *   try {
-   *     for(Row row : bigtableDataClient.readRows(query)) {
+   *     ServerStream<Row> stream = bigtableDataClient.readRows(query);
+   *     int count = 0;
+   *
+   *     // Iterator style
+   *     for (Row row : stream) {
+   *       if (++count > 10) {
+   *         stream.cancel();
+   *         break;
+   *       }
    *       // Do something with row
    *     }
    *   } catch (NotFoundException e) {
@@ -548,8 +555,17 @@ public ServerStream<Row> readRows(Query query) {
    *          .filter(FILTERS.qualifier().regex("[COLUMN PREFIX].*"));
    *
    *   bigtableDataClient.readRowsAsync(query, new ResponseObserver<Row>() {
-   *     public void onStart(StreamController controller) { }
+   *     StreamController controller;
+   *     int count = 0;
+   *
+   *     public void onStart(StreamController controller) {
+   *       this.controller = controller;
+   *     }
    *     public void onResponse(Row row) {
+   *       if (++count > 10) {
+   *         controller.cancel();
+   *         return;
+   *       }
    *       // Do something with Row
    *     }
    *     public void onError(Throwable t) {
