helper method to construct BigQueryDynamicReadDescriptor

Author: stankiewicz

examples/java/src/main/java/org/apache/beam/examples/cookbook/BigQueryStreamingTornadoes.java

@@ -178,8 +178,8 @@ public static void applyBigQueryStreamingTornadoes(Pipeline p, Options options)
                 MapElements.into(TypeDescriptor.of(BigQueryDynamicReadDescriptor.class))
                     .via(
                         (Instant t) ->
-                            BigQueryDynamicReadDescriptor.create(
-                                null, WEATHER_SAMPLES_TABLE, null, null, null, null)));
+                            BigQueryDynamicReadDescriptor.table(
+                                WEATHER_SAMPLES_TABLE, null, null)));
 
     PCollection<TableRow> readDynamically =
         descriptors.apply("Read dynamically", BigQueryIO.readDynamicallyTableRows());

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryDynamicReadDescriptor.java

@@ -88,4 +88,14 @@ public static BigQueryDynamicReadDescriptor create(
     return new AutoValue_BigQueryDynamicReadDescriptor(
         query, table, flattenResults, legacySql, selectedFields, rowRestriction);
   }
+
+  public static BigQueryDynamicReadDescriptor query(
+      String query, Boolean flattenResults, Boolean legacySql) {
+    return create(query, null, flattenResults, legacySql, null, null);
+  }
+
+  public static BigQueryDynamicReadDescriptor table(
+      String table, @Nullable List<String> selectedFields, @Nullable String rowRestriction) {
+    return create(null, table, null, null, selectedFields, rowRestriction);
+  }
 }