diff --git a/sdks/python/apache_beam/transforms/core.py b/sdks/python/apache_beam/transforms/core.py index a3762adac0cb..c6560ee4357e 100644 --- a/sdks/python/apache_beam/transforms/core.py +++ b/sdks/python/apache_beam/transforms/core.py @@ -1156,7 +1156,7 @@ def merge_accumulators(self, accumulators, *args, **kwargs): raise NotImplementedError(str(self)) def compact(self, accumulator, *args, **kwargs): - """Optionally returns a more compact represenation of the accumulator. + """Optionally returns a more compact representation of the accumulator. This is called before an accumulator is sent across the wire, and can be useful in cases where values are buffered or otherwise lazily