src/main/java/org/embulk/output/PostgresUDFOutputPlugin.java in embulk-output-postgres-udf-0.1.2 vs src/main/java/org/embulk/output/PostgresUDFOutputPlugin.java in embulk-output-postgres-udf-0.2.0
- old
+ new
@@ -74,11 +74,11 @@
public ConfigDiff resume(TaskSource taskSource, Schema schema, int taskCount, OutputPlugin.Control control) {
throw new UnsupportedOperationException("postgres-udf output plugin does not support resuming");
}
@Override
- public void cleanup(TaskSource taskSource, Schema schema, int taskCount, List<CommitReport> successCommitReports) {
+ public void cleanup(TaskSource taskSource, Schema schema, int taskCount, List<TaskReport> successTaskReports) {
PluginTask task = taskSource.loadTask(PluginTask.class);
try {
ConnectionWrapper con = getConnector(task).connect(true);
con.dropFunction(getFunctionName(), schema);
} catch (SQLException e) {
@@ -195,17 +195,17 @@
throw Throwables.propagate(e);
}
}
@Override
- public CommitReport commit() {
+ public TaskReport commit() {
try {
connection.commit();
}
catch (Exception e) {
throw Throwables.propagate(e);
}
- return Exec.newCommitReport();
+ return Exec.newTaskReport();
}
}
}