embulk-standards/src/main/java/org/embulk/standards/LocalFileOutputPlugin.java in embulk-0.2.1 vs embulk-standards/src/main/java/org/embulk/standards/LocalFileOutputPlugin.java in embulk-0.3.0

@@ -45,13 +45,26 @@
     public NextConfig transaction(ConfigSource config, int processorCount,
             FileOutputPlugin.Control control)
     {
         PluginTask task = config.loadConfig(PluginTask.class);
 
-        control.run(task.dump());
+        return resume(task.dump(), processorCount, control);
+    }
 
+    @Override
+    public NextConfig resume(TaskSource taskSource,
+            int processorCount,
+            FileOutputPlugin.Control control)
+    {
+        control.run(taskSource);
         return Exec.newNextConfig();
     }
+
+    @Override
+    public void cleanup(TaskSource taskSource,
+            int processorCount,
+            List<CommitReport> successCommitReports)
+    { }
 
     @Override
     public TransactionalFileOutput open(TaskSource taskSource, final int processorIndex)
     {
         PluginTask task = taskSource.loadTask(PluginTask.class);