4
4
import org .apache .hadoop .conf .Configuration ;
5
5
import org .apache .hadoop .fs .FileSystem ;
6
6
import org .apache .hadoop .fs .Path ;
7
- import org .apache .hadoop .util .Progressable ;
8
7
import org .embulk .config .*;
9
- import org .embulk .spi .*;
8
+ import org .embulk .spi .Buffer ;
9
+ import org .embulk .spi .Exec ;
10
+ import org .embulk .spi .FileOutputPlugin ;
11
+ import org .embulk .spi .TransactionalFileOutput ;
10
12
import org .jruby .embed .ScriptingContainer ;
11
13
import org .slf4j .Logger ;
12
14
@@ -30,7 +32,7 @@ public interface PluginTask extends Task
30
32
public Map <String , String > getConfig ();
31
33
32
34
@ Config ("sequence_format" )
33
- @ ConfigDefault ("\" . %03d.%02d\" " )
35
+ @ ConfigDefault ("\" %03d.%02d\" " )
34
36
public String getSequenceFormat ();
35
37
36
38
@ Config ("output_path" )
@@ -142,14 +144,7 @@ public void nextFile() {
142
144
if (fs .exists (currentPath )) {
143
145
throw new IllegalAccessException (currentPath .toString () + "already exists." );
144
146
}
145
- currentStream = fs .create (
146
- currentPath ,
147
- new Progressable () {
148
- @ Override
149
- public void progress () {
150
- logger .info ("{} byte written." , 1 );
151
- }
152
- });
147
+ currentStream = fs .create (currentPath );
153
148
logger .info ("Uploading '{}'" , currentPath .toString ());
154
149
}
155
150
catch (IOException | IllegalAccessException e ) {
0 commit comments