src/main/java/org/embulk/input/gcs/GcsFileInputPlugin.java in embulk-input-gcs-0.1.4 vs src/main/java/org/embulk/input/gcs/GcsFileInputPlugin.java in embulk-input-gcs-0.1.5
- old
+ new
@@ -10,19 +10,19 @@
import java.math.BigInteger;
import com.google.common.collect.ImmutableList;
import com.google.common.base.Optional;
import java.security.GeneralSecurityException;
-import org.embulk.config.CommitReport;
+import org.embulk.config.TaskReport;
import org.embulk.config.Config;
import org.embulk.config.ConfigInject;
import org.embulk.config.ConfigDiff;
import org.embulk.config.ConfigDefault;
import org.embulk.config.ConfigSource;
import org.embulk.config.Task;
import org.embulk.config.TaskSource;
-import org.embulk.config.CommitReport;
+import org.embulk.config.TaskReport;
import org.embulk.spi.Exec;
import org.embulk.spi.BufferAllocator;
import org.embulk.spi.FileInputPlugin;
import org.embulk.spi.TransactionalFileInput;
import org.embulk.spi.util.InputStreamFileInput;
@@ -45,34 +45,34 @@
{
public interface PluginTask
extends Task
{
@Config("bucket")
- public String getBucket();
+ String getBucket();
@Config("path_prefix")
- public String getPathPrefix();
+ String getPathPrefix();
@Config("last_path")
@ConfigDefault("null")
- public Optional<String> getLastPath();
+ Optional<String> getLastPath();
@Config("service_account_email")
- public String getServiceAccountEmail();
+ String getServiceAccountEmail();
@Config("application_name")
@ConfigDefault("\"Embulk GCS input plugin\"")
- public String getApplicationName();
+ String getApplicationName();
@Config("p12_keyfile_fullpath")
- public String getP12KeyfileFullpath();
+ String getP12KeyfileFullpath();
- public List<String> getFiles();
- public void setFiles(List<String> files);
+ List<String> getFiles();
+ void setFiles(List<String> files);
@ConfigInject
- public BufferAllocator getBufferAllocator();
+ BufferAllocator getBufferAllocator();
}
private static final Logger log = Exec.getLogger(GcsFileInputPlugin.class);
private static HttpTransport httpTransport;
private static JsonFactory jsonFactory;
@@ -122,11 +122,11 @@
}
@Override
public void cleanup(TaskSource taskSource,
int taskCount,
- List<CommitReport> successCommitReports)
+ List<TaskReport> successTaskReports)
{
}
/**
* @see https://developers.google.com/accounts/docs/OAuth2ServiceAccount#authorizingrequests
@@ -281,12 +281,12 @@
super(task.getBufferAllocator(), new SingleFileProvider(task, taskIndex));
}
public void abort() { }
- public CommitReport commit()
+ public TaskReport commit()
{
- return Exec.newCommitReport();
+ return Exec.newTaskReport();
}
@Override
public void close() { }
}