X-Git-Url: http://erislabs.net/gitweb/?a=blobdiff_plain;f=source%2Fmircoders%2Fproducer%2FIndexingProducerNode.java;fp=source%2Fmircoders%2Fproducer%2FIndexingProducerNode.java;h=8ed55a33ede1f977a7adb2e01746c24dcc1e0ad7;hb=6b6b6215ebe066b81f1fa6b0c71a532ca7b4fc3f;hp=8be3d6342ee01b19e72e496b1938355a99bbd01d;hpb=afcbbd1dee154b4d24a4a77dacc7e07503dd182c;p=mir.git diff --git a/source/mircoders/producer/IndexingProducerNode.java b/source/mircoders/producer/IndexingProducerNode.java index 8be3d634..8ed55a33 100755 --- a/source/mircoders/producer/IndexingProducerNode.java +++ b/source/mircoders/producer/IndexingProducerNode.java @@ -29,40 +29,31 @@ */ package mircoders.producer; -import java.io.File; -import java.text.SimpleDateFormat; -import java.util.Calendar; -import java.util.Date; -import java.util.GregorianCalendar; -import java.util.Map; - import mir.entity.Entity; import mir.entity.adapter.EntityAdapter; import mir.log.LoggerWrapper; import mir.misc.StringUtil; +import mir.producer.AbstractProducerNode; import mir.producer.ProducerFailure; -import mir.producer.ProducerNode; -import mir.util.FileFunctions; +import mir.util.FileRoutines; import mir.util.ParameterExpander; import mircoders.entity.EntityContent; -import mircoders.search.AudioSearchTerm; -import mircoders.search.ContentSearchTerm; -import mircoders.search.ImagesSearchTerm; -import mircoders.search.IndexUtil; -import mircoders.search.KeywordSearchTerm; -import mircoders.search.TextSearchTerm; -import mircoders.search.TopicSearchTerm; -import mircoders.search.UnIndexedSearchTerm; -import mircoders.search.VideoSearchTerm; - +import mircoders.search.*; import org.apache.lucene.analysis.standard.StandardAnalyzer; import org.apache.lucene.document.Document; import org.apache.lucene.index.IndexReader; import org.apache.lucene.index.IndexWriter; import org.apache.lucene.store.FSDirectory; +import java.io.File; +import java.text.SimpleDateFormat; +import java.util.Calendar; +import java.util.Date; +import java.util.GregorianCalendar; +import java.util.Map; + -public class IndexingProducerNode implements ProducerNode { +public class IndexingProducerNode extends AbstractProducerNode { private String contentKey; private String indexPath; private File indexBasePath; @@ -85,7 +76,7 @@ public class IndexingProducerNode implements ProducerNode { startTime = System.currentTimeMillis(); try { - indexFile = FileFunctions.getAbsoluteOrRelativeFile(indexBasePath, ParameterExpander.expandExpression(aValueMap, indexPath)); + indexFile = FileRoutines.getAbsoluteOrRelativeFile(indexBasePath, ParameterExpander.expandExpression(aValueMap, indexPath)); data = ParameterExpander.findValueForKey(aValueMap, contentKey); if (!(data instanceof EntityAdapter)) { @@ -102,11 +93,11 @@ public class IndexingProducerNode implements ProducerNode { entity.getClass().getName() + " adapter", null); } - aLogger.info("Indexing " + entity.getFieldValue("id") + " into " + indexFile.getAbsolutePath()); + aLogger.debug("Indexing " + entity.getFieldValue("id") + " into " + indexFile.getAbsolutePath()); // create an index here if one did not already exist if (!(IndexReader.indexExists(indexFile))) { - aLogger.error("Didn't find existing index, so I'm making one in " + indexFile.getAbsolutePath()); + aLogger.warn("Didn't find existing index, so I'm making one in " + indexFile.getAbsolutePath()); IndexWriter indexCreator = new IndexWriter(indexFile, new StandardAnalyzer(), true); indexCreator.close(); @@ -149,8 +140,7 @@ public class IndexingProducerNode implements ProducerNode { formattedDate = formatter.format(date); } catch (Throwable t) { - aLogger.error("Error while generating content date to index: " + t.getMessage()); - t.printStackTrace(aLogger.asPrintWriter(LoggerWrapper.DEBUG_MESSAGE)); + aLogger.warn("Error while generating content date to index", t); } } (new KeywordSearchTerm("webdb_create_formatted", "search_date", @@ -208,7 +198,7 @@ public class IndexingProducerNode implements ProducerNode { indexWriter.close(); } catch (Throwable t) { - aLogger.warn("Error while closing indexWriter: " + t.getMessage()); + aLogger.warn("Error while closing indexWriter", t); } } @@ -221,13 +211,13 @@ public class IndexingProducerNode implements ProducerNode { } } catch (Throwable t) { - aLogger.warn("Error while unlocking index: " + t.getMessage()); + aLogger.warn("Error while unlocking index", t); } } } endTime = System.currentTimeMillis(); - aLogger.info(" IndexTime: " + (endTime - startTime) + " ms
"); + aLogger.debug(" IndexTime: " + (endTime - startTime) + " ms
"); } }