org.apache.tika.eval.batch

Class EvalConsumerBuilder

java.lang.Object

org.apache.tika.eval.batch.EvalConsumerBuilder

Direct Known Subclasses:

ExtractComparerBuilder, ExtractProfilerBuilder

public abstract class EvalConsumerBuilder
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected ArrayBlockingQueue<FileResource>	queue

Constructor Summary

Constructors

Constructor and Description
EvalConsumerBuilder()

Method Summary

Modifier and Type	Method and 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 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 Detail

queue

protected ArrayBlockingQueue<FileResource> queue

Constructor Detail

EvalConsumerBuilder

public EvalConsumerBuilder()

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)

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

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)