Fix javadoc errors

apache · Apr 24, 2017 · ac9e386 · ac9e386
1 parent ebbb72a
commit ac9e386
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/MetricsAccumulator.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/MetricsAccumulator.java
@@ -120,7 +120,7 @@ private static void checkpoint() throws IOException {
  }
 
  /**
- * Spark Listener which checkpoints {@link SparkMetricsContainer} values for fault-tolerance.
+ * Spark Listener which checkpoints {@link MetricsContainers} values for fault-tolerance.
  */
  public static class AccumulatorCheckpointingSparkListener extends JavaStreamingListener {
  @Override

diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/SparkBeamMetricSource.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/SparkBeamMetricSource.java
@@ -25,7 +25,7 @@
 
 /**
  * A Spark {@link Source} that is tailored to expose a {@link SparkBeamMetric},
- * wrapping an underlying {@link SparkMetricsContainer} instance.
+ * wrapping an underlying {@link org.apache.beam.sdk.metrics.MetricResults} instance.
  */
 public class SparkBeamMetricSource implements Source {
  private static final String METRIC_NAME = "Metrics";

diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/StateSpecFunctions.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/StateSpecFunctions.java
@@ -112,8 +112,8 @@ public Tuple2<Iterable<byte[]>, Metadata> apply(
  scala.Option<CheckpointMarkT> startCheckpointMark,
  State<Tuple2<byte[], Instant>> state) {
 
- MetricsContainers sparkMetricsContainer = new MetricsContainers();
- MetricsContainer metricsContainer = sparkMetricsContainer.getContainer(stepName);
+ MetricsContainers metricsContainers = new MetricsContainers();
+ MetricsContainer metricsContainer = metricsContainers.getContainer(stepName);
 
  // Add metrics container to the scope of org.apache.beam.sdk.io.Source.Reader methods
  // since they may report metrics.
@@ -211,7 +211,7 @@ public Tuple2<Iterable<byte[]>, Metadata> apply(
  lowWatermark,
  highWatermark,
  readDurationMillis,
- sparkMetricsContainer));
+ metricsContainers));
 
  } catch (IOException e) {
  throw new RuntimeException(e);