embulk-standards/src/main/java/org/embulk/standards/StdoutOutputPlugin.java in embulk-0.4.3 vs embulk-standards/src/main/java/org/embulk/standards/StdoutOutputPlugin.java in embulk-0.4.4

- old
+ new

@@ -25,33 +25,33 @@ { } @Override public ConfigDiff transaction(ConfigSource config, - Schema schema, int processorCount, + Schema schema, int taskCount, OutputPlugin.Control control) { final PluginTask task = config.loadConfig(PluginTask.class); - return resume(task.dump(), schema, processorCount, control); + return resume(task.dump(), schema, taskCount, control); } @Override public ConfigDiff resume(TaskSource taskSource, - Schema schema, int processorCount, + Schema schema, int taskCount, OutputPlugin.Control control) { control.run(taskSource); return Exec.newConfigDiff(); } public void cleanup(TaskSource taskSource, - Schema schema, int processorCount, + Schema schema, int taskCount, List<CommitReport> successCommitReports) { } @Override public TransactionalPageOutput open(TaskSource taskSource, final Schema schema, - int processorIndex) + int taskIndex) { final PluginTask task = taskSource.loadTask(PluginTask.class); return new TransactionalPageOutput() { private final PageReader reader = new PageReader(schema);