You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/08/10 16:58:44 UTC
[1/2] incubator-beam git commit: fixed typo in aggregator_test.py
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 0358e6e8f -> 127e763c1
fixed typo in aggregator_test.py
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1672ec7d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1672ec7d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1672ec7d
Branch: refs/heads/python-sdk
Commit: 1672ec7d3f2ab309ca003e7920c42499553ff4e5
Parents: 65152ca
Author: Seunghyun Lee <sh...@gmail.com>
Authored: Fri Aug 5 13:35:12 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Aug 10 09:53:34 2016 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/transforms/aggregator_test.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/1672ec7d/sdks/python/apache_beam/transforms/aggregator_test.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/transforms/aggregator_test.py b/sdks/python/apache_beam/transforms/aggregator_test.py
index 0b3a20b..040819e 100644
--- a/sdks/python/apache_beam/transforms/aggregator_test.py
+++ b/sdks/python/apache_beam/transforms/aggregator_test.py
@@ -55,18 +55,18 @@ class AggregatorTest(unittest.TestCase):
(any, int, True),
(all, float, False),
]
- aggeregators = [Aggregator('%s_%s' % (f.__name__, t.__name__), f, t)
- for f, t, _ in counter_types]
+ aggregators = [Aggregator('%s_%s' % (f.__name__, t.__name__), f, t)
+ for f, t, _ in counter_types]
class UpdateAggregators(beam.DoFn):
def process(self, context):
- for a in aggeregators:
+ for a in aggregators:
context.aggregate_to(a, context.element)
p = beam.Pipeline('DirectPipelineRunner')
p | beam.Create([0, 1, 2, 3]) | beam.ParDo(UpdateAggregators()) # pylint: disable=expression-not-assigned
res = p.run()
- for (_, _, expected), a in zip(counter_types, aggeregators):
+ for (_, _, expected), a in zip(counter_types, aggregators):
actual = res.aggregated_values(a).values()[0]
self.assertEqual(expected, actual)
self.assertEqual(type(expected), type(actual))
[2/2] incubator-beam git commit: This closes #798
Posted by ke...@apache.org.
This closes #798
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/127e763c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/127e763c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/127e763c
Branch: refs/heads/python-sdk
Commit: 127e763c1cbfc0080061bdbb4525e6774c1e8b28
Parents: 0358e6e 1672ec7
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed Aug 10 09:58:32 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Aug 10 09:58:32 2016 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/transforms/aggregator_test.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------