Skip to content

Commit

Permalink
modify for embulk upgrade from 0.6.11 to 0.7.4
Browse files Browse the repository at this point in the history
  • Loading branch information
tzmfreedom committed Oct 4, 2015
1 parent eb01c25 commit 4641cac
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 9 deletions.
6 changes: 3 additions & 3 deletions build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -12,11 +12,11 @@ configurations {
provided
}

version = "0.1.2"
version = "0.1.3"

dependencies {
compile "org.embulk:embulk-core:0.6.11"
provided "org.embulk:embulk-core:0.6.11"
compile "org.embulk:embulk-core:0.7.4"
provided "org.embulk:embulk-core:0.7.4"
// compile "YOUR_JAR_DEPENDENCY_GROUP:YOUR_JAR_DEPENDENCY_MODULE:YOUR_JAR_DEPENDENCY_VERSION"
compile "net.sf.supercsv:super-csv:2.3.1"
compile files('lib/force-wsc-34.0.jar', 'lib/partner.jar')
Expand Down
Binary file modified gradle/wrapper/gradle-wrapper.jar
Binary file not shown.
4 changes: 2 additions & 2 deletions gradle/wrapper/gradle-wrapper.properties
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
#Wed Feb 04 13:46:12 PST 2015
#Tue Aug 11 00:26:20 PDT 2015
distributionBase=GRADLE_USER_HOME
distributionPath=wrapper/dists
zipStoreBase=GRADLE_USER_HOME
zipStorePath=wrapper/dists
distributionUrl=https\://services.gradle.org/distributions/gradle-2.2.1-bin.zip
distributionUrl=https\://services.gradle.org/distributions/gradle-2.6-bin.zip
8 changes: 4 additions & 4 deletions src/main/java/org/embulk/output/SalesforceOutputPlugin.java
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.embulk.config.CommitReport;
import org.embulk.config.TaskReport;
import org.embulk.config.Config;
import org.embulk.config.ConfigDefault;
import org.embulk.config.ConfigDiff;
Expand Down Expand Up @@ -148,7 +148,7 @@ public ConfigDiff resume(TaskSource taskSource,
@Override
public void cleanup(TaskSource taskSource,
Schema schema, int taskCount,
List<CommitReport> successCommitReports)
List<TaskReport> successTaskReports)
{
logger.info("logout");
try {
Expand Down Expand Up @@ -295,9 +295,9 @@ public void abort()
}

@Override
public CommitReport commit()
public TaskReport commit()
{
return Exec.newCommitReport();
return Exec.newTaskReport();
}

private void action(List<SObject> records) throws ConnectionException, IOException{
Expand Down

0 comments on commit 4641cac

Please sign in to comment.