Thomas Groh created BEAM-2620:
---------------------------------
Summary: Revisit GroupByKey.createWithFewKeys
Key: BEAM-2620
URL: https://issues.apache.org/jira/browse/BEAM-2620
Project: Beam
Issue Type: Bug
Components: beam-model, beam-model-runner-api, sdk-java-core
Reporter: Thomas Groh
This doesn't have a parallel within the GroupByKeyPayload, so there's currently
no way to send it through the Runner API.
The place it will almost always be created is in a {{Combine.globally()}}.
It's potentially useful as an optimizer hint. The Dataflow Runner in streaming
mode disables combiner lifting unless the GroupByKey has the fewKeys property
set to true.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)