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

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

queue

protected ArrayBlockingQueue<FileResource> queue

Constructor Details

EvalConsumerBuilder

public EvalConsumerBuilder()

Method Details

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)

getRefTableInfos

protected abstract List<TableInfo> getRefTableInfos()

Returns:

only the ref tables

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)