You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2019/06/24 18:15:02 UTC
[beam] branch asf-site updated: Publishing website 2019/06/24
18:14:51 at commit 0f862ba
This is an automated email from the ASF dual-hosted git repository.
git-site-role pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/asf-site by this push:
new ec06c1e Publishing website 2019/06/24 18:14:51 at commit 0f862ba
ec06c1e is described below
commit ec06c1edb3b2d579f3770225d770e87a8bcae90f
Author: jenkins <bu...@apache.org>
AuthorDate: Mon Jun 24 18:14:52 2019 +0000
Publishing website 2019/06/24 18:14:51 at commit 0f862ba
---
.../documentation/io/developing-io-python/index.html | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/website/generated-content/documentation/io/developing-io-python/index.html b/website/generated-content/documentation/io/developing-io-python/index.html
index c1e59a4..d2e3ca3 100644
--- a/website/generated-content/documentation/io/developing-io-python/index.html
+++ b/website/generated-content/documentation/io/developing-io-python/index.html
@@ -625,14 +625,14 @@ a wrapper.</li>
return OffsetRangeTracker(start_position, stop_position)
def read(self, range_tracker):
- for i in range(self._count):
+ for i in range(range_tracker.start_position(),
+ range_tracker.stop_position()):
if not range_tracker.try_claim(i):
return
self.records_read.inc()
yield i
- def split(self, desired_bundle_size, start_position=None,
- stop_position=None):
+ def split(self, desired_bundle_size, start_position=None, stop_position=None):
if start_position is None:
start_position = 0
if stop_position is None:
@@ -640,7 +640,7 @@ a wrapper.</li>
bundle_start = start_position
while bundle_start < stop_position:
- bundle_stop = max(stop_position, bundle_start + desired_bundle_size)
+ bundle_stop = min(stop_position, bundle_start + desired_bundle_size)
yield iobase.SourceBundle(weight=(bundle_stop - bundle_start),
source=self,
start_position=bundle_start,