Repository: beam Updated Branches: refs/heads/master cc12fd378 -> 806c53c18
Remove two unused fields Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/30f36344 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/30f36344 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/30f36344 Branch: refs/heads/master Commit: 30f363444679293727171f2417c9d991a4bf7852 Parents: cc12fd3 Author: Eugene Kirpichov <[email protected]> Authored: Thu Mar 2 17:54:55 2017 -0800 Committer: Thomas Groh <[email protected]> Committed: Tue Mar 14 15:54:19 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java | 7 ------- 1 file changed, 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/30f36344/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java index 0e1c6fc..2902c2b 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java @@ -130,7 +130,6 @@ import org.apache.beam.sdk.values.PCollectionView; import org.apache.beam.sdk.values.PDone; import org.apache.beam.sdk.values.TupleTag; import org.apache.beam.sdk.values.TupleTagList; -import org.joda.time.Duration; import org.joda.time.Instant; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -1189,15 +1188,9 @@ public class BigQueryIO { * ... */ private abstract static class BigQuerySourceBase extends BoundedSource<TableRow> { - // The maximum number of retries to verify temp files. - private static final int MAX_FILES_VERIFY_RETRIES = 9; - // The maximum number of retries to poll a BigQuery job. protected static final int JOB_POLL_MAX_RETRIES = Integer.MAX_VALUE; - // The initial backoff for verifying temp files. - private static final Duration INITIAL_FILES_VERIFY_BACKOFF = Duration.standardSeconds(1); - protected final ValueProvider<String> jobIdToken; protected final String extractDestinationDir; protected final BigQueryServices bqServices;
