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(); } } }