public class FSConsumersManager extends ConsumersManager
| Constructor and Description | 
|---|
| FSConsumersManager(List<FileResourceConsumer> consumers) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | init()This is called by BatchProcess before submitting the threads | 
| void | shutdown()This is called by BatchProcess immediately before closing. | 
getConsumers, getConsumersManagerMaxMillis, setConsumersManagerMaxMillispublic FSConsumersManager(List<FileResourceConsumer> consumers)
public void init()
ConsumersManagerinit in class ConsumersManagerpublic void shutdown()
ConsumersManagershutdown in class ConsumersManagerCopyright © 2007–2021 The Apache Software Foundation. All rights reserved.