[BEAM-1871] Remove google api BackOff usage from sdks/core This closes #2982
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5763c384 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5763c384 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5763c384 Branch: refs/heads/release-2.0.0 Commit: 5763c384d122d4c9c09d93f780dc5f65f09e9a27 Parents: e282601 8ea53a4 Author: Luke Cwik <[email protected]> Authored: Tue May 9 09:55:16 2017 -0700 Committer: Luke Cwik <[email protected]> Committed: Tue May 9 09:55:16 2017 -0700 ---------------------------------------------------------------------- .../beam/examples/common/ExampleUtils.java | 6 +- .../beam/examples/WindowedWordCountIT.java | 2 +- .../runners/dataflow/DataflowPipelineJob.java | 18 +++- .../beam/runners/dataflow/util/PackageUtil.java | 3 +- .../dataflow/DataflowPipelineJobTest.java | 13 ++- .../runners/dataflow/util/PackageUtilTest.java | 2 +- runners/spark/pom.xml | 5 - .../beam/runners/spark/io/MicrobatchSource.java | 2 +- sdks/java/core/pom.xml | 5 - .../beam/sdk/coders/StructuralByteArray.java | 4 +- .../sdk/io/BoundedReadFromUnboundedSource.java | 2 +- .../beam/sdk/testing/FileChecksumMatcher.java | 2 +- .../beam/sdk/testing/MatcherDeserializer.java | 4 +- .../beam/sdk/testing/MatcherSerializer.java | 4 +- .../java/org/apache/beam/sdk/util/BackOff.java | 81 ++++++++++++++++ .../org/apache/beam/sdk/util/BackOffUtils.java | 57 ++++++++++++ .../org/apache/beam/sdk/util/CoderUtils.java | 10 +- .../beam/sdk/util/ExplicitShardedFile.java | 3 - .../org/apache/beam/sdk/util/FluentBackoff.java | 1 - .../beam/sdk/util/NumberedShardedFile.java | 3 - .../org/apache/beam/sdk/util/ShardedFile.java | 2 - .../java/org/apache/beam/sdk/util/Sleeper.java | 48 ++++++++++ .../sdk/util/UploadIdResponseInterceptor.java | 60 ------------ .../org/apache/beam/SdkCoreApiSurfaceTest.java | 1 - .../beam/sdk/testing/ExpectedLogsTest.java | 2 +- .../sdk/testing/FastNanoClockAndSleeper.java | 47 ---------- .../testing/FastNanoClockAndSleeperTest.java | 47 ---------- .../sdk/testing/FileChecksumMatcherTest.java | 5 - .../beam/sdk/testing/SystemNanoTimeSleeper.java | 2 +- .../apache/beam/sdk/util/FluentBackoffTest.java | 1 - .../beam/sdk/util/NumberedShardedFileTest.java | 14 ++- .../util/UploadIdResponseInterceptorTest.java | 98 -------------------- .../sdk/extensions/gcp/options/GcpOptions.java | 3 +- .../apache/beam/sdk/util/BackOffAdapter.java | 43 +++++++++ .../java/org/apache/beam/sdk/util/GcsUtil.java | 13 ++- .../sdk/util/UploadIdResponseInterceptor.java | 60 ++++++++++++ .../beam/sdk/util/FastNanoClockAndSleeper.java | 47 ++++++++++ .../sdk/util/FastNanoClockAndSleeperTest.java | 47 ++++++++++ .../org/apache/beam/sdk/util/GcsUtilTest.java | 23 +++-- .../util/UploadIdResponseInterceptorTest.java | 98 ++++++++++++++++++++ .../io/gcp/bigquery/BigQueryServicesImpl.java | 81 +++++++--------- .../gcp/bigquery/BigQueryTableRowIterator.java | 7 +- .../beam/sdk/io/gcp/datastore/DatastoreV1.java | 6 +- .../gcp/bigquery/BigQueryServicesImplTest.java | 24 +++-- .../sdk/io/gcp/bigquery/FakeJobService.java | 12 ++- .../beam/sdk/io/gcp/datastore/V1TestUtil.java | 6 +- .../sdk/io/gcp/testing/BigqueryMatcher.java | 4 +- .../sdk/io/gcp/testing/BigqueryMatcherTest.java | 7 +- 48 files changed, 633 insertions(+), 402 deletions(-) ----------------------------------------------------------------------
