src/main/java/org/embulk/output/HdfsOutputPlugin.java in embulk-output-hdfs-0.1.1 vs src/main/java/org/embulk/output/HdfsOutputPlugin.java in embulk-output-hdfs-0.1.2

- old
+ new

@@ -65,11 +65,11 @@ @Override public void cleanup(TaskSource taskSource, int taskCount, - List<CommitReport> successCommitReports) + List<TaskReport> successTaskReports) { } @Override public TransactionalFileOutput open(TaskSource taskSource, final int taskIndex) @@ -186,19 +186,19 @@ @Override public void abort() { } @Override - public CommitReport commit() { + public TaskReport commit() { try { fs.rename(new Path(workingPath), new Path(outputPath)); logger.info("rename {} => {}", workingPath, outputPath); } catch (IOException e) { logger.error(e.getMessage()); throw Throwables.propagate(e); } - CommitReport report = Exec.newCommitReport(); + TaskReport report = Exec.newTaskReport(); report.set("files", currentPath); return report; } private void closeCurrentStream() {