[
https://issues.apache.org/jira/browse/BEAM-5195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vaclav Plajt resolved BEAM-5195.
--------------------------------
Resolution: Fixed
Fix Version/s: Not applicable
> Add support for `TopPerKey` operator
> ------------------------------------
>
> Key: BEAM-5195
> URL: https://issues.apache.org/jira/browse/BEAM-5195
> Project: Beam
> Issue Type: Sub-task
> Components: dsl-euphoria
> Reporter: Vaclav Plajt
> Assignee: Vaclav Plajt
> Priority: Major
> Fix For: Not applicable
>
>
> `TopPerKey` operator is not supported due to its decomposition to
> `ReduceStateByKey` operator which is not supported. That decomposition is
> wrong since it outputs one value per key so no state is needed to perform the
> reduction.
> Change decomposition of `TopPerKey` to `ReduceByKey`. That will make
> `TopPerKey` translatable to Beam API.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
