Update Dataflow Spanner ReadAll sample. (GoogleCloudPlatform#1403)

munkhuushmgl · May 3, 2019 · 7fd4ef4 · 7fd4ef4
1 parent 62006b7
commit 7fd4ef4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/dataflow/spanner-io/pom.xml b/dataflow/spanner-io/pom.xml
@@ -38,7 +38,7 @@
     <java.version>1.8</java.version>
     <maven.compiler.source>1.8</maven.compiler.source>
     <maven.compiler.target>1.8</maven.compiler.target>
-    <apache_beam.version>2.3.0</apache_beam.version>
+    <apache_beam.version>2.5.0</apache_beam.version>
   </properties>
 
   <build>

diff --git a/dataflow/spanner-io/src/main/java/com/example/dataflow/SpannerReadAll.java b/dataflow/spanner-io/src/main/java/com/example/dataflow/SpannerReadAll.java
@@ -69,6 +69,7 @@ public static void main(String[] args) {
     // [START spanner_dataflow_readall]
     PCollection<Struct> allRecords = p.apply(SpannerIO.read()
         .withSpannerConfig(spannerConfig)
+        .withBatching(false)
         .withQuery("SELECT t.table_name FROM information_schema.tables AS t WHERE t"
             + ".table_catalog = '' AND t.table_schema = ''")).apply(
         MapElements.into(TypeDescriptor.of(ReadOperation.class))