embulk-standards/src/main/java/org/embulk/standards/LocalFileOutputPlugin.java in embulk-0.6.16 vs embulk-standards/src/main/java/org/embulk/standards/LocalFileOutputPlugin.java in embulk-0.6.17

- old
+ new

@@ -80,13 +80,12 @@ final String pathPrefix = task.getPathPrefix(); final String pathSuffix = task.getFileNameExtension(); final String sequenceFormat = task.getSequenceFormat(); - final List<String> fileNames = new ArrayList<>(); - return new TransactionalFileOutput() { + private final List<String> fileNames = new ArrayList<>(); private int fileIndex = 0; private FileOutputStream output = null; public void nextFile() { @@ -132,10 +131,11 @@ public void close() { closeFile(); } - public void abort() { } + public void abort() + { } public CommitReport commit() { CommitReport report = Exec.newCommitReport(); // TODO better setting for Report