diff options
Diffstat (limited to 'docproc/src/main/java/com/yahoo/docproc/Call.java')
-rw-r--r-- | docproc/src/main/java/com/yahoo/docproc/Call.java | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/docproc/src/main/java/com/yahoo/docproc/Call.java b/docproc/src/main/java/com/yahoo/docproc/Call.java index 3598ddaff6c..c640dbcf832 100644 --- a/docproc/src/main/java/com/yahoo/docproc/Call.java +++ b/docproc/src/main/java/com/yahoo/docproc/Call.java @@ -11,7 +11,6 @@ import com.yahoo.document.DocumentPut; import com.yahoo.document.DocumentUpdate; import com.yahoo.jdisc.Metric; import com.yahoo.concurrent.SystemTimer; -import com.yahoo.statistics.Counter; import com.yahoo.statistics.Statistics; import java.util.List; @@ -25,14 +24,12 @@ import java.util.List; public class Call implements Cloneable { private final DocumentProcessor processor; - private final Counter docCounter; private final String docCounterName; - private final Counter procTimeCounter; private final String procTimeCounterName; private final Metric metric; public Call(DocumentProcessor processor) { - this(processor, Statistics.nullImplementation, new NullMetric()); + this(processor, new NullMetric()); } /** @@ -40,11 +37,19 @@ public class Call implements Cloneable { * * @param processor the document processor to call */ + public Call(DocumentProcessor processor, Metric metric) { + this(processor, "", metric); + } + @Deprecated public Call(DocumentProcessor processor, Statistics manager, Metric metric) { - this(processor, "", manager, metric); + this(processor, "", metric); } - + @Deprecated public Call(DocumentProcessor processor, String chainName, Statistics manager, Metric metric) { + this(processor, chainName, metric); + } + + public Call(DocumentProcessor processor, String chainName, Metric metric) { this.processor = processor; if (chainName == null) chainName = ""; @@ -53,8 +58,6 @@ public class Call implements Cloneable { getDocumentProcessorId().stringValue().replaceAll("[^\\p{Alnum}]", "_") + "_documents"; procTimeCounterName = "docprocessor_" + chainName + "_" + getDocumentProcessorId().stringValue().replaceAll("[^\\p{Alnum}]", "_") + "_proctime"; - docCounter = new Counter(docCounterName, manager, false); - procTimeCounter = new Counter(procTimeCounterName, manager, false, null, true); this.metric = metric; } @@ -171,12 +174,10 @@ public class Call implements Cloneable { } private void incrementDocs(long increment) { - docCounter.increment(increment); metric.add(docCounterName, increment, null); } private void incrementProcTime(long increment) { - procTimeCounter.increment(increment); metric.add(procTimeCounterName, increment, null); } |