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 <bui...@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,