Skip to content

Commit f8dbba1

Browse files
Improve docstring for PGBKCVOperation (#37946)
* Improve docstring for PGBKCVOperation * Fix docstring is satisfy lint * Add costring for PGBKCVOperation * Revert untended .gitignore changes
1 parent 2eb71e9 commit f8dbba1

2 files changed

Lines changed: 5 additions & 1 deletion

File tree

sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_test.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@
3939
from .groupby_two_exprs import groupby_two_exprs
4040

4141

42-
4342
class UnorderedList(object):
4443
def __init__(self, contents):
4544
self._contents = list(contents)

sdks/python/apache_beam/runners/worker/operations.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1234,6 +1234,11 @@ def flush(self, target):
12341234

12351235

12361236
class PGBKCVOperation(Operation):
1237+
"""Partial group-by-key operation.
1238+
1239+
This operation handles grouped values with
1240+
a combine function applied.
1241+
"""
12371242
def __init__(
12381243
self, name_context, spec, counter_factory, state_sampler, windowing=None):
12391244
super(PGBKCVOperation,

0 commit comments

Comments
 (0)