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 <[email protected]> Authored: Tue May 17 14:33:41 2016 -0700 Committer: Priyanka Gugale <[email protected]> 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
