Add support for setting an HTTP read timeout for BigQueryIO

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

@@ -39,7 +39,14 @@ public interface BigQueryOptions
   void setTempDatasetId(String value);
 
   @Description(
-      "Timeout for HTTP requests to BigQuery service in milliseconds. Set to 0 to disable.")
+      "Timeout for HTTP read requests to BigQuery service in milliseconds. Set to 0 to disable.")
+  @Default.Integer(80 * 1000)
+  Integer getHTTPReadTimeout();
+
+  void setHTTPReadTimeout(Integer timeout);
+
+  @Description(
+      "Timeout for HTTP write requests to BigQuery service in milliseconds. Set to 0 to disable.")
   @Default.Integer(900 * 1000)
   Integer getHTTPWriteTimeout();
 

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

@@ -1584,6 +1584,7 @@ private static Bigquery.Builder newBigQueryClient(BigQueryOptions options) {
     RetryHttpRequestInitializer httpRequestInitializer =
         new RetryHttpRequestInitializer(ImmutableList.of(404));
     httpRequestInitializer.setCustomErrors(createBigQueryClientCustomErrors());
+    httpRequestInitializer.setReadTimeout(options.getHTTPReadTimeout());
     httpRequestInitializer.setWriteTimeout(options.getHTTPWriteTimeout());
     ImmutableList.Builder<HttpRequestInitializer> initBuilder = ImmutableList.builder();
     Credentials credential = options.getGcpCredential();