Sign in
apache
/
beam
/
6a095456aa35f5a2623fa58644f44bf36cefa081
/
.
/
sdks
/
python
/
apache_beam
/
examples
/
snippets
/
transforms
/
aggregation
tree: 198a143cd9a61b8b57c6f8f746d08756bdf41c41 [
path history
]
[
tgz
]
__init__.py
approximatequantiles.py
approximatequantiles_test.py
approximateunique.py
approximateunique_test.py
batchelements.py
batchelements_test.py
cogroupbykey.py
cogroupbykey_test.py
combineglobally_combinefn.py
combineglobally_function.py
combineglobally_lambda.py
combineglobally_multiple_arguments.py
combineglobally_side_inputs_dict.py
combineglobally_side_inputs_iter.py
combineglobally_side_inputs_singleton.py
combineglobally_test.py
combineperkey_combinefn.py
combineperkey_function.py
combineperkey_lambda.py
combineperkey_multiple_arguments.py
combineperkey_side_inputs_dict.py
combineperkey_side_inputs_iter.py
combineperkey_side_inputs_singleton.py
combineperkey_simple.py
combineperkey_test.py
combinevalues_combinefn.py
combinevalues_function.py
combinevalues_lambda.py
combinevalues_multiple_arguments.py
combinevalues_side_inputs_dict.py
combinevalues_side_inputs_iter.py
combinevalues_side_inputs_singleton.py
combinevalues_simple.py
combinevalues_test.py
count_globally.py
count_per_element.py
count_per_key.py
count_test.py
distinct.py
distinct_test.py
groupby_attr.py
groupby_attr_expr.py
groupby_expr.py
groupby_expr_aggregate.py
groupby_global_aggregate.py
groupby_simple_aggregate.py
groupby_test.py
groupby_two_exprs.py
groupbykey.py
groupbykey_test.py
groupintobatches.py
groupintobatches_test.py
latest_globally.py
latest_per_key.py
latest_test.py
max_globally.py
max_per_key.py
max_test.py
mean_globally.py
mean_per_key.py
mean_test.py
min_globally.py
min_per_key.py
min_test.py
sample_fixed_size_globally.py
sample_fixed_size_per_key.py
sample_test.py
sum_globally.py
sum_per_key.py
sum_test.py
tolist.py
tolist_test.py
top_largest.py
top_largest_per_key.py
top_of.py
top_per_key.py
top_smallest.py
top_smallest_per_key.py
top_test.py