Closes #888
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a2c22388 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a2c22388 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a2c22388 Branch: refs/heads/master Commit: a2c2238890b48341a58c57d849515be535763acd Parents: ca97a13 dbbcbe6 Author: Dan Halperin <[email protected]> Authored: Sun Sep 4 12:00:14 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Sun Sep 4 12:00:14 2016 -0700 ---------------------------------------------------------------------- .../beam/examples/common/ExampleUtils.java | 7 +- .../runners/dataflow/DataflowPipelineJob.java | 72 +++--- .../beam/runners/dataflow/util/PackageUtil.java | 31 +-- .../dataflow/DataflowPipelineJobTest.java | 32 ++- .../sdk/io/BoundedReadFromUnboundedSource.java | 8 +- ...AttemptAndTimeBoundedExponentialBackOff.java | 172 -------------- .../util/AttemptBoundedExponentialBackOff.java | 85 ------- .../org/apache/beam/sdk/util/FluentBackoff.java | 229 +++++++++++++++++++ .../java/org/apache/beam/sdk/util/GcsUtil.java | 18 +- .../util/IntervalBoundedExponentialBackOff.java | 1 + ...mptAndTimeBoundedExponentialBackOffTest.java | 212 ----------------- .../AttemptBoundedExponentialBackOffTest.java | 84 ------- .../apache/beam/sdk/util/FluentBackoffTest.java | 226 ++++++++++++++++++ .../org/apache/beam/sdk/util/GcsUtilTest.java | 10 +- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 21 +- .../io/gcp/bigquery/BigQueryServicesImpl.java | 152 ++++++------ .../gcp/bigquery/BigQueryTableRowIterator.java | 5 +- .../beam/sdk/io/gcp/datastore/DatastoreV1.java | 26 +-- .../gcp/bigquery/BigQueryServicesImplTest.java | 17 +- .../beam/sdk/io/gcp/datastore/V1TestUtil.java | 9 +- 20 files changed, 675 insertions(+), 742 deletions(-) ----------------------------------------------------------------------
