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() {