You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by re...@apache.org on 2014/10/22 02:03:25 UTC
[03/10] git commit: Added java doc
Added java doc
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/393c2e79
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/393c2e79
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/393c2e79
Branch: refs/heads/master
Commit: 393c2e79b2534bb7f8ba344b6418488c84338c87
Parents: 6916a1b
Author: Ryan Ebanks <ry...@gmail.com>
Authored: Fri Oct 17 18:03:04 2014 -0500
Committer: Ryan Ebanks <ry...@gmail.com>
Committed: Fri Oct 17 18:03:04 2014 -0500
----------------------------------------------------------------------
.../org/apache/streams/local/counters/StreamsTaskCounter.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/393c2e79/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/counters/StreamsTaskCounter.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/counters/StreamsTaskCounter.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/counters/StreamsTaskCounter.java
index e864219..a0eb349 100644
--- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/counters/StreamsTaskCounter.java
+++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/counters/StreamsTaskCounter.java
@@ -42,6 +42,10 @@ public class StreamsTaskCounter implements StreamsTaskCounterMXBean{
@GuardedBy("this")
private volatile long maxTime;
+ /**
+ *
+ * @param id
+ */
public StreamsTaskCounter(String id) {
this.emitted = new AtomicLong(0);
this.received = new AtomicLong(0);