You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by bh...@apache.org on 2016/05/25 20:25:30 UTC
[3/4] incubator-apex-malhar git commit: Removing autometrics
Removing autometrics
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/b047b825
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/b047b825
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/b047b825
Branch: refs/heads/master
Commit: b047b82540b0526247e8a8bd925b66d1f38bffbe
Parents: 802cfce
Author: Priyanka Gugale <pr...@datatorrent.com>
Authored: Tue May 17 14:33:41 2016 -0700
Committer: Priyanka Gugale <pr...@datatorrent.com>
Committed: Tue May 17 14:33:41 2016 -0700
----------------------------------------------------------------------
.../contrib/cassandra/AbstractCassandraInputOperator.java | 5 -----
1 file changed, 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/b047b825/contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractCassandraInputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractCassandraInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractCassandraInputOperator.java
index 0f2f0d0..7bd47fc 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractCassandraInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractCassandraInputOperator.java
@@ -28,7 +28,6 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.datatorrent.lib.db.AbstractStoreInputOperator;
-import com.datatorrent.api.AutoMetric;
import com.datatorrent.api.DefaultOutputPort;
import com.datatorrent.netlet.util.DTThrowable;
@@ -50,14 +49,11 @@ public abstract class AbstractCassandraInputOperator<T> extends AbstractStoreInp
private PagingState nextPageState;
private int fetchSize;
int waitForDataTimeout = 100;
- @AutoMetric
- protected long tuplesRead;
@Override
public void beginWindow(long l)
{
super.beginWindow(l);
- tuplesRead = 0;
}
/**
@@ -128,7 +124,6 @@ public abstract class AbstractCassandraInputOperator<T> extends AbstractStoreInp
for (Row row : result) {
T tuple = getTuple(row);
emit(tuple);
- tuplesRead++;
}
} else {
// No rows available wait for some time before retrying so as to not continuously slam the database