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/09/20 00:54:40 UTC
[1/2] incubator-beam git commit: Changed ToStringCoder to BytesCoder
in test
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 2f09003e3 -> adda16320
Changed ToStringCoder to BytesCoder in test
The former can't be used with sources, as it can only encode.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/19a8407f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/19a8407f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/19a8407f
Branch: refs/heads/python-sdk
Commit: 19a8407f741848db0dc86e587ea9739b17888768
Parents: 2f09003
Author: Gus Katsiapis <ka...@katsiapis-linux.mtv.corp.google.com>
Authored: Mon Sep 19 17:21:45 2016 -0700
Committer: Robert Bradshaw <ro...@google.com>
Committed: Mon Sep 19 17:53:44 2016 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/io/sources_test.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/19a8407f/sdks/python/apache_beam/io/sources_test.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/io/sources_test.py b/sdks/python/apache_beam/io/sources_test.py
index 45c5ab8..293f437 100644
--- a/sdks/python/apache_beam/io/sources_test.py
+++ b/sdks/python/apache_beam/io/sources_test.py
@@ -24,6 +24,7 @@ import unittest
import apache_beam as beam
+from apache_beam import coders
from apache_beam.io import iobase
from apache_beam.io import range_trackers
from apache_beam.transforms.util import assert_that
@@ -76,7 +77,7 @@ class LineSource(iobase.BoundedSource):
return range_trackers.OffsetRangeTracker(start_position, stop_position)
def default_output_coder(self):
- return beam.coders.ToStringCoder()
+ return coders.BytesCoder()
class SourcesTest(unittest.TestCase):
[2/2] incubator-beam git commit: Closes #976
Posted by ro...@apache.org.
Closes #976
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/adda1632
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/adda1632
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/adda1632
Branch: refs/heads/python-sdk
Commit: adda1632015043e352c75e2f9966cc04a458b30c
Parents: 2f09003 19a8407
Author: Robert Bradshaw <ro...@google.com>
Authored: Mon Sep 19 17:54:27 2016 -0700
Committer: Robert Bradshaw <ro...@google.com>
Committed: Mon Sep 19 17:54:27 2016 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/io/sources_test.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------