You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2016/10/11 18:24:03 UTC
[4/4] incubator-beam git commit: Post-merge fixup.
Post-merge fixup.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/eb57b974
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/eb57b974
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/eb57b974
Branch: refs/heads/python-sdk
Commit: eb57b974c1ca9d231e614debaf40f686da9e4e02
Parents: 46110e4
Author: Robert Bradshaw <ro...@google.com>
Authored: Tue Oct 11 11:23:27 2016 -0700
Committer: Robert Bradshaw <ro...@google.com>
Committed: Tue Oct 11 11:23:27 2016 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/io/fileio_test.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/eb57b974/sdks/python/apache_beam/io/fileio_test.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/io/fileio_test.py b/sdks/python/apache_beam/io/fileio_test.py
index 42ea9ff..45435e6 100644
--- a/sdks/python/apache_beam/io/fileio_test.py
+++ b/sdks/python/apache_beam/io/fileio_test.py
@@ -466,8 +466,8 @@ class TestTextFileSource(unittest.TestCase):
for percent_complete in percents_complete:
self.try_splitting_reader_at(
reader,
- iobase.DynamicSplitRequest(
- iobase.ReaderProgress(percent_complete=percent_complete)),
+ dataflow_io.DynamicSplitRequest(
+ dataflow_io.ReaderProgress(percent_complete=percent_complete)),
None)
# Cursor passed beginning of file.
@@ -477,8 +477,8 @@ class TestTextFileSource(unittest.TestCase):
for percent_complete in percents_complete:
self.try_splitting_reader_at(
reader,
- iobase.DynamicSplitRequest(
- iobase.ReaderProgress(percent_complete=percent_complete)),
+ dataflow_io.DynamicSplitRequest(
+ dataflow_io.ReaderProgress(percent_complete=percent_complete)),
None)
def test_zlib_file_unsplittable(self):