Hi,

I've read the documentation for CombinePerKey with hot key fanout and I
think I understand it at a high level (split up and combine sharded keys
before merging all values in one key) but I'm confused by the parameter
that this method takes and how it affects the behavior of the transform.

Is the fanout parameter the... number of shards per key? Am I thinking
about this right? Any help would be appreciated, thanks!

Joey

[1]
https://beam.apache.org/releases/pydoc/current/apache_beam.transforms.core.html#apache_beam.transforms.core.CombinePerKey.with_hot_key_fanout

Reply via email to