Skip to content

Commit 7f48023

Browse files
committed
migrate as new embulk API.
1 parent 579d796 commit 7f48023

File tree

4 files changed

+8
-8
lines changed

4 files changed

+8
-8
lines changed

build.gradle

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,8 +15,8 @@ configurations {
1515
version = "0.2.0"
1616

1717
dependencies {
18-
compile "org.embulk:embulk-core:0.5.2"
19-
provided "org.embulk:embulk-core:0.5.2"
18+
compile "org.embulk:embulk-core:0.7.0"
19+
provided "org.embulk:embulk-core:0.7.0"
2020
compile "com.amazonaws:aws-java-sdk-s3:1.9.24"
2121
testCompile "junit:junit:4.+"
2222
}

gradle/wrapper/gradle-wrapper.jar

-330 Bytes
Binary file not shown.
Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
#Wed Feb 04 13:46:12 PST 2015
1+
#Tue Aug 11 00:26:20 PDT 2015
22
distributionBase=GRADLE_USER_HOME
33
distributionPath=wrapper/dists
44
zipStoreBase=GRADLE_USER_HOME
55
zipStorePath=wrapper/dists
6-
distributionUrl=https\://services.gradle.org/distributions/gradle-2.2.1-bin.zip
6+
distributionUrl=https\://services.gradle.org/distributions/gradle-2.6-bin.zip

src/main/java/org/embulk/output/S3FileOutputPlugin.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
import java.util.List;
99
import java.util.Locale;
1010

11-
import org.embulk.config.CommitReport;
11+
import org.embulk.config.TaskReport;
1212
import org.embulk.config.Config;
1313
import org.embulk.config.ConfigDefault;
1414
import org.embulk.config.ConfigDiff;
@@ -210,8 +210,8 @@ public void abort() {
210210
}
211211

212212
@Override
213-
public CommitReport commit() {
214-
CommitReport report = Exec.newCommitReport();
213+
public TaskReport commit() {
214+
TaskReport report = Exec.newTaskReport();
215215
return report;
216216
}
217217
}
@@ -247,7 +247,7 @@ public ConfigDiff resume(TaskSource taskSource, int taskCount,
247247

248248
@Override
249249
public void cleanup(TaskSource taskSource, int taskCount,
250-
List<CommitReport> successCommitReports) {
250+
List<TaskReport> successTaskReports) {
251251
}
252252

253253
@Override

0 commit comments

Comments
 (0)