[
https://issues.apache.org/jira/browse/BEAM-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía reassigned BEAM-2811:
----------------------------------
Assignee: (was: Amit Sela)
> Complete the removal of aggregators from Spark runner.
> ------------------------------------------------------
>
> Key: BEAM-2811
> URL: https://issues.apache.org/jira/browse/BEAM-2811
> Project: Beam
> Issue Type: Task
> Components: runner-spark
> Reporter: Aviem Zur
> Priority: Major
>
> In https://issues.apache.org/jira/browse/BEAM-1765 aggregator usage was
> removed from Spark runner in order to comply with the removal of aggregators
> from the SDK.
> However, not all classes / usages of aggregators within the Spark runner were
> removed.
> This task is to complete the removal of all aggregator code from Spark
> runner, including, but not limited to:
> {code}
> org.apache.beam.runners.spark.aggregators.AggAccumParam
> org.apache.beam.runners.spark.aggregators.AggregatorsAccumulator
> org.apache.beam.runners.spark.aggregators.NamedAggregators
> org.apache.beam.runners.spark.metrics.AggregatorMetricSource
> org.apache.beam.runners.spark.metrics.AggregatorMetric
> {code}
> In addition, remove packages named {{aggregators}} and move any remaining
> relevant classes to {{org.apache.beam.runners.spark.metrics}} package.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
