This closes #2171
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b6ca062f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b6ca062f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b6ca062f Branch: refs/heads/master Commit: b6ca062fcfa31884baf08b804d04c12dee10b62e Parents: d167153 874c8d0 Author: Stas Levin <stasle...@apache.org> Authored: Sun Mar 12 10:02:30 2017 +0200 Committer: Stas Levin <stasle...@apache.org> Committed: Sun Mar 12 10:02:30 2017 +0200 ---------------------------------------------------------------------- .../spark/SparkNativePipelineVisitor.java | 4 -- .../beam/runners/spark/SparkPipelineResult.java | 8 +-- .../apache/beam/runners/spark/SparkRunner.java | 65 ++++++++++---------- .../beam/runners/spark/SparkRunnerDebugger.java | 30 ++++++--- .../beam/runners/spark/TestSparkRunner.java | 4 +- .../aggregators/AggregatorsAccumulator.java | 44 +++++++++---- .../spark/aggregators/SparkAggregators.java | 40 ++---------- .../spark/metrics/AggregatorMetricSource.java | 11 ++-- .../spark/metrics/MetricsAccumulator.java | 38 ++++++++---- .../spark/metrics/SparkBeamMetricSource.java | 11 ++-- .../spark/metrics/SparkMetricsContainer.java | 17 ++--- .../spark/translation/TransformTranslator.java | 13 ++-- .../SparkRunnerStreamingContextFactory.java | 3 + .../streaming/StreamingTransformTranslator.java | 10 +-- .../metrics/sink/NamedAggregatorsTest.java | 15 +---- .../ResumeFromCheckpointStreamingTest.java | 4 +- 16 files changed, 156 insertions(+), 161 deletions(-) ----------------------------------------------------------------------
