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–2022 The Apache Software Foundation. All rights reserved.