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, setConsumersManagerMaxMillis
public DBConsumersManager(JDBCUtil dbUtil, MimeBuffer mimeBuffer, List<FileResourceConsumer> consumers) throws SQLException
SQLException
public void shutdown()
ConsumersManager
shutdown
in class ConsumersManager
Copyright © 2007–2018 The Apache Software Foundation. All rights reserved.