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() { } }