aboutsummaryrefslogtreecommitdiffstats
path: root/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingTask.java
diff options
context:
space:
mode:
Diffstat (limited to 'docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingTask.java')
-rw-r--r--docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingTask.java12
1 files changed, 3 insertions, 9 deletions
diff --git a/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingTask.java b/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingTask.java
index e629953ccff..f7f8d0e6a10 100644
--- a/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingTask.java
+++ b/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingTask.java
@@ -4,10 +4,10 @@ package com.yahoo.docproc.jdisc;
import com.yahoo.collections.Tuple2;
import com.yahoo.docproc.Call;
import com.yahoo.docproc.CallStack;
-import com.yahoo.docproc.DocprocExecutor;
-import com.yahoo.docproc.DocprocService;
+import com.yahoo.docproc.impl.DocprocExecutor;
+import com.yahoo.docproc.impl.DocprocService;
import com.yahoo.docproc.DocumentProcessor;
-import com.yahoo.docproc.HandledProcessingException;
+import com.yahoo.docproc.impl.HandledProcessingException;
import com.yahoo.docproc.Processing;
import java.util.logging.Level;
import com.yahoo.yolean.Exceptions;
@@ -19,7 +19,6 @@ import java.util.Iterator;
import java.util.List;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ThreadPoolExecutor;
-import java.util.logging.Level;
import java.util.logging.Logger;
/**
@@ -34,11 +33,9 @@ public class DocumentProcessingTask implements Runnable {
private final DocumentProcessingHandler docprocHandler;
private final RequestContext requestContext;
- @SuppressWarnings("removal") // TODO Vespa 8: remove
private final DocprocService service;
private final ThreadPoolExecutor executor;
- @SuppressWarnings("removal") // TODO Vespa 8: remove
public DocumentProcessingTask(RequestContext requestContext, DocumentProcessingHandler docprocHandler,
DocprocService service, ThreadPoolExecutor executor) {
this.requestContext = requestContext;
@@ -67,7 +64,6 @@ public class DocumentProcessingTask implements Runnable {
return;
}
- @SuppressWarnings("removal") // TODO Vespa 8: remove
DocprocExecutor executor = service.getExecutor();
DocumentProcessor.Progress progress = process(executor);
@@ -91,7 +87,6 @@ public class DocumentProcessingTask implements Runnable {
*
* @param executor the DocprocService to use for processing
*/
- @SuppressWarnings("removal") // TODO Vespa 8: remove
private DocumentProcessor.Progress process(DocprocExecutor executor) {
Iterator<Processing> iterator = processings.iterator();
List<Tuple2<DocumentProcessor.Progress, Processing>> later = new ArrayList<>();
@@ -188,7 +183,6 @@ public class DocumentProcessingTask implements Runnable {
'}';
}
- @SuppressWarnings("removal") // TODO Vespa 8: remove
private static void logProcessingFailure(Processing processing, Exception exception) {
//LOGGING ONLY:
String errorMsg = processing + " failed at " + processing.callStack().getLastPopped();