public class DBConsumersManager extends ConsumersManager
| Constructor and Description |
|---|
DBConsumersManager(JDBCUtil dbUtil,
MimeBuffer mimeBuffer,
List<FileResourceConsumer> consumers) |
| Modifier and Type | Method and Description |
|---|---|
void |
addErrorLogTablePair(Path log,
TableInfo tableInfo) |
void |
shutdown()
This is called by BatchProcess immediately before closing.
|
getConsumers, getConsumersManagerMaxMillis, init, setConsumersManagerMaxMillispublic DBConsumersManager(JDBCUtil dbUtil, MimeBuffer mimeBuffer, List<FileResourceConsumer> consumers) throws SQLException
SQLExceptionpublic void shutdown()
ConsumersManagershutdown in class ConsumersManagerCopyright © 2007–2022 The Apache Software Foundation. All rights reserved.