Skip to content

Commit

Permalink
Merge pull request #7 from civitaspo/v0.1.2
Browse files Browse the repository at this point in the history
embulk migrate!!
  • Loading branch information
civitaspo committed Aug 19, 2015
2 parents dec5fff + f036df1 commit 7e3e716
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 8 deletions.
6 changes: 3 additions & 3 deletions build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -12,14 +12,14 @@ configurations {
provided
}

version = "0.1.1"
version = "0.1.2"

sourceCompatibility = 1.7
targetCompatibility = 1.7

dependencies {
compile "org.embulk:embulk-core:0.6.16"
provided "org.embulk:embulk-core:0.6.16"
compile "org.embulk:embulk-core:0.7.0"
provided "org.embulk:embulk-core:0.7.0"
// compile "YOUR_JAR_DEPENDENCY_GROUP:YOUR_JAR_DEPENDENCY_MODULE:YOUR_JAR_DEPENDENCY_VERSION"
compile 'org.apache.hadoop:hadoop-client:2.6.0'
compile 'com.google.guava:guava:14.0'
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
6 changes: 3 additions & 3 deletions src/main/java/org/embulk/output/HdfsOutputPlugin.java
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ public ConfigDiff resume(TaskSource taskSource,
@Override
public void cleanup(TaskSource taskSource,
int taskCount,
List<CommitReport> successCommitReports)
List<TaskReport> successTaskReports)
{
}

Expand Down Expand Up @@ -188,7 +188,7 @@ public void abort() {
}

@Override
public CommitReport commit() {
public TaskReport commit() {
try {
fs.rename(new Path(workingPath), new Path(outputPath));
logger.info("rename {} => {}", workingPath, outputPath);
Expand All @@ -197,7 +197,7 @@ public CommitReport commit() {
throw Throwables.propagate(e);
}

CommitReport report = Exec.newCommitReport();
TaskReport report = Exec.newTaskReport();
report.set("files", currentPath);
return report;
}
Expand Down

0 comments on commit 7e3e716

Please sign in to comment.