public abstract class EvalConsumerBuilder extends Object
Modifier and Type | Field and Description |
---|---|
protected ArrayBlockingQueue<FileResource> |
queue |
Constructor and Description |
---|
EvalConsumerBuilder() |
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 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) |
protected ArrayBlockingQueue<FileResource> queue
public MimeBuffer init(ArrayBlockingQueue<FileResource> queue, Map<String,String> localAttrs, JDBCUtil dbUtil, boolean forceDrop) throws IOException, SQLException
IOException
SQLException
public abstract FileResourceConsumer build() throws IOException, SQLException
IOException
SQLException
protected abstract void updateTableInfosWithPrefixes(Map<String,String> attrs)
protected abstract List<TableInfo> getNonRefTableInfos()
protected abstract TableInfo getMimeTable()
protected abstract void addErrorLogTablePairs(DBConsumersManager manager)
public void populateRefTables() throws IOException, SQLException
IOException
SQLException
protected IDBWriter getDBWriter(List<TableInfo> tableInfos) throws IOException, SQLException
IOException
SQLException
protected ExtractReader buildExtractReader(Map<String,String> localAttrs)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.