You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/10 00:12:34 UTC
[03/50] incubator-apex-core git commit: Fixed documentation and spaces
Fixed documentation and spaces
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/6d0fde61
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/6d0fde61
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/6d0fde61
Branch: refs/heads/master
Commit: 6d0fde610da6ecc3617402310d044bd91e2ccc8a
Parents: 0f9fb47
Author: Chandni Singh <ch...@datatorrent.com>
Authored: Fri Jul 31 10:55:18 2015 -0700
Committer: thomas <th...@datatorrent.com>
Committed: Tue Aug 4 11:11:37 2015 -0700
----------------------------------------------------------------------
api/src/main/java/com/datatorrent/api/AutoMetric.java | 11 +++++------
1 file changed, 5 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/6d0fde61/api/src/main/java/com/datatorrent/api/AutoMetric.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/AutoMetric.java b/api/src/main/java/com/datatorrent/api/AutoMetric.java
index 23c3be3..61e8dd0 100644
--- a/api/src/main/java/com/datatorrent/api/AutoMetric.java
+++ b/api/src/main/java/com/datatorrent/api/AutoMetric.java
@@ -39,19 +39,18 @@ public @interface AutoMetric
/**
* @return map of metric name to value
*/
- Map<String, Object> getMetrics();
+ Map<String, Object> getMetrics();
/**
- *
* @return operator id
*/
- int operatorId();
+ int operatorId();
}
/**
* It aggregates metrics from multiple physical partitions of an operator to a logical one.<br/>
- * An aggregator is provided as operator attribute. By default when there isn't any aggregator set the engine does
- * summation of a number metric.
+ * An aggregator is provided as operator attribute. By default, when there isn't any aggregator set explicitly,
+ * the application master sums up all the number metrics.
*/
public static interface Aggregator
{
@@ -98,7 +97,7 @@ public @interface AutoMetric
* to aggregations. Stram will invoke this method for each logical metric and check if the aggregations are overwritten
* and will inform that to app data tracker.
*
- * @param logicalMetricName logical metric name.
+ * @param logicalMetricName logical metric name.
* @return aggregations eg. SUM, MIN, MAX, etc. that will be performed by app data tracker on a logical metric.
*/
String[] getDimensionAggregationsFor(String logicalMetricName);