beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [1/2] incubator-beam git commit: fixed typo in aggregator_test.py
Date Wed, 10 Aug 2016 16:58:44 GMT
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 <shlee0605@gmail.com>
Authored: Fri Aug 5 13:35:12 2016 -0700
Committer: Kenneth Knowles <klk@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))


Mime
View raw message