src/main/java/org/embulk/executor/mapreduce/EmbulkPartitioningMapReduce.java in embulk-executor-mapreduce-0.1.5 vs src/main/java/org/embulk/executor/mapreduce/EmbulkPartitioningMapReduce.java in embulk-executor-mapreduce-0.2.0

@@ -10,11 +10,11 @@
 import org.apache.hadoop.io.IntWritable;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.mapreduce.Mapper;
 import org.apache.hadoop.mapreduce.Reducer;
 import org.embulk.config.ModelManager;
-import org.embulk.config.CommitReport;
+import org.embulk.config.TaskReport;
 import org.embulk.config.ConfigDiff;
 import org.embulk.config.TaskSource;
 import org.embulk.config.ConfigSource;
 import org.embulk.spi.Exec;
 import org.embulk.spi.ExecAction;
@@ -216,11 +216,11 @@
                 public Void run() throws Exception
                 {
                     try {
                         if (!failed) {
                             output.finish();
-                            CommitReport report = output.commit();
+                            TaskReport report = output.commit();
                             handler.outputCommitted(report);
                         }
                     } finally {
                         output.close();
                     }
@@ -264,11 +264,11 @@
             throw new RuntimeException("");
         }
 
         public void cleanup(TaskSource taskSource,
                 Schema schema, int taskCount,
-                List<CommitReport> successCommitReports)
+                List<TaskReport> successTaskReports)
         {
             // won't be called
             throw new RuntimeException("");
         }
 
@@ -299,12 +299,12 @@
                 }
 
                 public void abort()
                 { }
 
-                public CommitReport commit()
+                public TaskReport commit()
                 {
-                    return Exec.newCommitReport();
+                    return Exec.newTaskReport();
                 }
             };
         }
     }
 }