You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ch...@apache.org on 2017/08/18 03:13:33 UTC
[1/2] beam git commit: Fixes a pydocs validation failure due to a
recent commit.
Repository: beam
Updated Branches:
refs/heads/master 8503adbbc -> 0aae7aa5f
Fixes a pydocs validation failure due to a recent commit.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8dc6e166
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8dc6e166
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8dc6e166
Branch: refs/heads/master
Commit: 8dc6e1666f3f113fe5ee854f4c7060e0fbd614e1
Parents: 8503adb
Author: chamikara@google.com <ch...@google.com>
Authored: Thu Aug 17 18:21:44 2017 -0700
Committer: chamikara@google.com <ch...@google.com>
Committed: Thu Aug 17 18:21:44 2017 -0700
----------------------------------------------------------------------
.../io/gcp/datastore/v1/adaptive_throttler.py | 16 ++++++++++------
1 file changed, 10 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/8dc6e166/sdks/python/apache_beam/io/gcp/datastore/v1/adaptive_throttler.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/io/gcp/datastore/v1/adaptive_throttler.py b/sdks/python/apache_beam/io/gcp/datastore/v1/adaptive_throttler.py
index 4dfd675..7d94f24 100644
--- a/sdks/python/apache_beam/io/gcp/datastore/v1/adaptive_throttler.py
+++ b/sdks/python/apache_beam/io/gcp/datastore/v1/adaptive_throttler.py
@@ -41,12 +41,16 @@ class AdaptiveThrottler(object):
MIN_REQUESTS = 1
def __init__(self, window_ms, bucket_ms, overload_ratio):
- """Args:
- window_ms: int, length of history to consider, in ms, to set throttling.
- bucket_ms: int, granularity of time buckets that we store data in, in ms.
- overload_ratio: float, the target ratio between requests sent and
- successful requests. This is "K" in the formula in
- https://landing.google.com/sre/book/chapters/handling-overload.html
+ """Initializes AdaptiveThrottler.
+
+ Args:
+ window_ms: int, length of history to consider, in ms, to set
+ throttling.
+ bucket_ms: int, granularity of time buckets that we store data in, in
+ ms.
+ overload_ratio: float, the target ratio between requests sent and
+ successful requests. This is "K" in the formula in
+ https://landing.google.com/sre/book/chapters/handling-overload.html.
"""
self._all_requests = util.MovingSum(window_ms, bucket_ms)
self._successful_requests = util.MovingSum(window_ms, bucket_ms)
[2/2] beam git commit: This closes #3731
Posted by ch...@apache.org.
This closes #3731
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0aae7aa5
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0aae7aa5
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0aae7aa5
Branch: refs/heads/master
Commit: 0aae7aa5fa1df0dbf8a0fb630c62842260df323a
Parents: 8503adb 8dc6e16
Author: chamikara@google.com <ch...@google.com>
Authored: Thu Aug 17 20:13:08 2017 -0700
Committer: chamikara@google.com <ch...@google.com>
Committed: Thu Aug 17 20:13:08 2017 -0700
----------------------------------------------------------------------
.../io/gcp/datastore/v1/adaptive_throttler.py | 16 ++++++++++------
1 file changed, 10 insertions(+), 6 deletions(-)
----------------------------------------------------------------------