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

@@ -1,7 +1,8 @@
 package org.embulk.standards;
 
+import java.util.List;
 import org.embulk.config.ConfigSource;
 import org.embulk.config.TaskSource;
 import org.embulk.config.NextConfig;
 import org.embulk.config.CommitReport;
 import org.embulk.config.Task;
@@ -28,12 +29,25 @@
     public NextConfig transaction(ConfigSource config,
             Schema schema, int processorCount,
             OutputPlugin.Control control)
     {
         final PluginTask task = config.loadConfig(PluginTask.class);
-        control.run(task.dump());
+        return resume(task.dump(), schema, processorCount, control);
+    }
+
+    @Override
+    public NextConfig resume(TaskSource taskSource,
+            Schema schema, int processorCount,
+            OutputPlugin.Control control)
+    {
+        control.run(taskSource);
         return Exec.newNextConfig();
     }
+
+    public void cleanup(TaskSource taskSource,
+            Schema schema, int processorCount,
+            List<CommitReport> successCommitReports)
+    { }
 
     @Override
     public TransactionalPageOutput open(TaskSource taskSource, final Schema schema,
             int processorIndex)
     {