diff options
Diffstat (limited to 'docprocs/src/main/java/com/yahoo/docprocs/indexing/IndexingProcessor.java')
-rw-r--r-- | docprocs/src/main/java/com/yahoo/docprocs/indexing/IndexingProcessor.java | 23 |
1 files changed, 4 insertions, 19 deletions
diff --git a/docprocs/src/main/java/com/yahoo/docprocs/indexing/IndexingProcessor.java b/docprocs/src/main/java/com/yahoo/docprocs/indexing/IndexingProcessor.java index 657c8a161f7..de4fee2ed68 100644 --- a/docprocs/src/main/java/com/yahoo/docprocs/indexing/IndexingProcessor.java +++ b/docprocs/src/main/java/com/yahoo/docprocs/indexing/IndexingProcessor.java @@ -29,10 +29,8 @@ import com.yahoo.vespa.indexinglanguage.SimpleAdapterFactory; import com.yahoo.vespa.indexinglanguage.expressions.Expression; import java.util.Map; -import java.util.logging.Level; import java.util.stream.Collectors; - /** * @author Simon Thoresen Hult */ @@ -45,7 +43,6 @@ public class IndexingProcessor extends DocumentProcessor { public final static String INDEXING_START = "indexingStart"; public final static String INDEXING_END = "indexingEnd"; - private final static FastLogger log = FastLogger.getLogger(IndexingProcessor.class.getName()); private final DocumentTypeManager docTypeMgr; private final ScriptManager scriptMgr; private final AdapterFactory adapterFactory; @@ -69,9 +66,8 @@ public class IndexingProcessor extends DocumentProcessor { @Override public Progress process(Processing proc) { - if (proc.getDocumentOperations().isEmpty()) { - return Progress.DONE; - } + if (proc.getDocumentOperations().isEmpty()) return Progress.DONE; + List<DocumentOperation> out = new ArrayList<>(proc.getDocumentOperations().size()); for (DocumentOperation documentOperation : proc.getDocumentOperations()) { if (documentOperation instanceof DocumentPut) { @@ -99,11 +95,9 @@ public class IndexingProcessor extends DocumentProcessor { DocumentType hadType = input.getDocument().getDataType(); DocumentScript script = scriptMgr.getScript(hadType); if (script == null) { - log.log(Level.FINE, "No indexing script for document '%s'.", input.getId()); out.add(input); return; } - log.log(Level.FINE, "Processing document '%s'.", input.getId()); DocumentType wantType = docTypeMgr.getDocumentType(hadType.getName()); Document inputDocument = input.getDocument(); if (hadType != wantType) { @@ -117,10 +111,7 @@ public class IndexingProcessor extends DocumentProcessor { inputDocument = docTypeMgr.createDocument(buffer); } Document output = script.execute(adapterFactory, inputDocument); - if (output == null) { - log.log(Level.FINE, "Document '%s' produced no output.", input.getId()); - return; - } + if (output == null) return; out.add(new DocumentPut(input, output)); } @@ -128,22 +119,16 @@ public class IndexingProcessor extends DocumentProcessor { private void processUpdate(DocumentUpdate input, List<DocumentOperation> out) { DocumentScript script = scriptMgr.getScript(input.getType()); if (script == null) { - log.log(Level.FINE, "No indexing script for update '%s'.", input.getId()); out.add(input); return; } - log.log(Level.FINE, "Processing update '%s'.", input.getId()); DocumentUpdate output = script.execute(adapterFactory, input); - if (output == null) { - log.log(Level.FINE, "Update '%s' produced no output.", input.getId()); - return; - } + if (output == null) return; output.setCondition(input.getCondition()); out.add(output); } private void processRemove(DocumentRemove input, List<DocumentOperation> out) { - log.log(Level.FINE, "Not processing remove '%s'.", input.getId()); out.add(input); } |