public class FileCollector
extends java.lang.Object
| Constructor and Description |
|---|
FileCollector(java.lang.String filePath,
java.lang.String inputFormat) |
| Modifier and Type | Method and Description |
|---|---|
HubConfig |
getHubConfig() |
DiskQueue<java.lang.String> |
run() |
void |
setHubConfig(HubConfig config) |