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