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 void
addErrorLogTablePairs(DBConsumersManager manager)
abstract FileResourceConsumer
build()
protected ExtractReader
buildExtractReader(Map<String,String> localAttrs)
protected IDBWriter
getDBWriter(List<TableInfo> tableInfos)
protected abstract TableInfo
getMimeTable()
protected abstract List<TableInfo>
getNonRefTableInfos()
protected abstract List<TableInfo>
getRefTableInfos()
MimeBuffer
init(ArrayBlockingQueue<FileResource> queue, Map<String,String> localAttrs, JDBCUtil dbUtil, boolean forceDrop)
void
populateRefTables()
protected abstract void
updateTableInfosWithPrefixes(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:
IOException
SQLException
-
build
public abstract FileResourceConsumer build() throws IOException, SQLException
- Throws:
IOException
SQLException
-
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:
IOException
SQLException
-
getDBWriter
protected IDBWriter getDBWriter(List<TableInfo> tableInfos) throws IOException, SQLException
- Throws:
IOException
SQLException
-
buildExtractReader
protected ExtractReader buildExtractReader(Map<String,String> localAttrs)
-
-