Package org.apache.tika.eval.app.batch
Class EvalConsumerBuilder
- java.lang.Object
-
- org.apache.tika.eval.app.batch.EvalConsumerBuilder
-
- Direct Known Subclasses:
ExtractComparerBuilder,ExtractProfilerBuilder,FileProfilerBuilder
public abstract class EvalConsumerBuilder extends Object
-
-
Field Summary
Fields Modifier and Type Field Description protected ArrayBlockingQueue<FileResource>queue
-
Constructor Summary
Constructors Constructor Description EvalConsumerBuilder()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract voidaddErrorLogTablePairs(DBConsumersManager manager)abstract FileResourceConsumerbuild()protected ExtractReaderbuildExtractReader(Map<String,String> localAttrs)protected IDBWritergetDBWriter(List<TableInfo> tableInfos)protected abstract TableInfogetMimeTable()protected abstract List<TableInfo>getNonRefTableInfos()protected abstract List<TableInfo>getRefTableInfos()MimeBufferinit(ArrayBlockingQueue<FileResource> queue, Map<String,String> localAttrs, JDBCUtil dbUtil, boolean forceDrop)voidpopulateRefTables()protected abstract voidupdateTableInfosWithPrefixes(Map<String,String> attrs)
-
-
-
Field Detail
-
queue
protected ArrayBlockingQueue<FileResource> queue
-
-
Method Detail
-
init
public MimeBuffer init(ArrayBlockingQueue<FileResource> queue, Map<String,String> localAttrs, JDBCUtil dbUtil, boolean forceDrop) throws IOException, SQLException
- Throws:
IOExceptionSQLException
-
build
public abstract FileResourceConsumer build() throws IOException, SQLException
- Throws:
IOExceptionSQLException
-
updateTableInfosWithPrefixes
protected abstract void updateTableInfosWithPrefixes(Map<String,String> attrs)
-
getNonRefTableInfos
protected abstract List<TableInfo> getNonRefTableInfos()
- Returns:
- the main tables, not including the ref tables
-
getMimeTable
protected abstract TableInfo getMimeTable()
-
addErrorLogTablePairs
protected abstract void addErrorLogTablePairs(DBConsumersManager manager)
-
populateRefTables
public void populateRefTables() throws IOException, SQLException- Throws:
IOExceptionSQLException
-
getDBWriter
protected IDBWriter getDBWriter(List<TableInfo> tableInfos) throws IOException, SQLException
- Throws:
IOExceptionSQLException
-
buildExtractReader
protected ExtractReader buildExtractReader(Map<String,String> localAttrs)
-
-