Commit 286c8e2b authored by yu's avatar yu

Trying to add the configuration of the multi dir tree

parent a0e2d2aa
......@@ -215,12 +215,16 @@ public class FilenameFileInputPlugin implements FileInputPlugin
FileInputPlugin.Control control)
{
PluginTask task = taskSource.loadTask(PluginTask.class);
log.info("The taskSource of the FileName in the ConfigDiff resume: " + taskSource.toString());
control.run(taskSource, taskCount);
log.info("Filename 1 stop point");
// Here the taskSource contains all the Configuration of the 'in'
log.info("The taskSource of the FileName in the ConfigDiff resume: " + taskSource.toString());
// Here will run all the tasks. Each task is to deal with a file.
control.run(taskSource, taskCount);
// build next config
ConfigDiff configDiff = Exec.newConfigDiff();
log.info("Filename 2 stop point");
// last_path
if (task.getFiles().isEmpty()) {
// keep the last value
......@@ -311,6 +315,8 @@ public class FilenameFileInputPlugin implements FileInputPlugin
public TransactionalFileInput open(TaskSource taskSource, int taskIndex)
{
final PluginTask task = taskSource.loadTask(PluginTask.class);
log.info("The task in open: " + taskSource.toString());
final String path = task.getFiles().get(taskIndex);
return new InputStreamTransactionalFileInput(
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment