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);