Added the queryTempDataset option for the BQ read options

v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryConverters.java

@@ -229,6 +229,18 @@
     String getQueryLocation();
 
     void setQueryLocation(String query);
+
+    @TemplateParameter.Text(
+        order = 6,
+        optional = true,
+        description = "BigQuery temporary dataset reference when reading from the query.",
+        helpText =
+            "With this option, you can set an existing dataset to create the temporary table "
+                + "to store the results of the query.",
+        example = "temp_dataset")
+    String getQueryTempDataset();
+
+    void setQueryTempDataset(String queryTempDataset);
   }
 
   /**
@@ -349,6 +361,7 @@
                   .fromQuery(options().getQuery())
                   .withTemplateCompatibility()
                   .withQueryLocation(options().getQueryLocation())
+                  .withQueryTempDataset(options().getQueryTempDataset())
                   .usingStandardSql());
         } else {
 
@@ -358,7 +371,8 @@
               readFunction()
                   .fromQuery(options().getQuery())
                   .withTemplateCompatibility()
-                  .withQueryLocation(options().getQueryLocation()));
+                  .withQueryLocation(options().getQueryLocation())
+                  .withQueryTempDataset(options().getQueryTempDataset()));
         }
       }
     }

v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/BigQueryConvertersTest.java

@@ -346,6 +346,20 @@ public void testReadBigQueryInvalidInput() {
     pipeline.run();
   }
 
+  /** Tests {@link BigQueryConverters.BigQueryReadOptions} works with some options. */
+  @Test
+  public void testBigQueryReadOptions() {
+
+    BigQueryConverters.BigQueryReadOptions options =
+        PipelineOptionsFactory.create().as(BigQueryConverters.BigQueryReadOptions.class);
+
+    options.setInputTableSpec(null);
+    options.setQuery("select * from sampledb.sample_table");
+    options.setQueryTempDataset("temp_dataset");
+
+    assertThat(options.getQueryTempDataset()).isEqualTo("temp_dataset");
+  }
+
   /**
    * Tests that {@link BigQueryConverters.TableRowToFailsafeJsonDocument} transform returns the
    * correct element.