src/main/java/org/embulk/input/gcs/GcsFileInputPlugin.java in embulk-input-gcs-0.2.8 vs src/main/java/org/embulk/input/gcs/GcsFileInputPlugin.java in embulk-input-gcs-0.3.0
- old
+ new
@@ -1,10 +1,8 @@
package org.embulk.input.gcs;
import com.google.api.services.storage.Storage;
-import com.google.common.base.Function;
-import com.google.common.base.Optional;
import com.google.common.base.Throwables;
import org.embulk.config.ConfigDiff;
import org.embulk.config.ConfigException;
import org.embulk.config.ConfigSource;
import org.embulk.config.TaskReport;
@@ -16,10 +14,12 @@
import org.slf4j.Logger;
import java.io.IOException;
import java.security.GeneralSecurityException;
import java.util.List;
+import java.util.Optional;
+import java.util.function.Function;
public class GcsFileInputPlugin
implements FileInputPlugin
{
private static final Logger log = Exec.getLogger(GcsFileInputPlugin.class);
@@ -84,11 +84,11 @@
{
try {
return new GcsAuthentication(
task.getAuthMethod().getString(),
task.getServiceAccountEmail(),
- task.getP12Keyfile().transform(localFileToPathString()),
- task.getJsonKeyfile().transform(localFileToPathString()),
+ task.getP12Keyfile().map(localFileToPathString()),
+ task.getJsonKeyfile().map(localFileToPathString()),
task.getApplicationName()
);
}
catch (GeneralSecurityException | IOException ex) {
throw new ConfigException(ex);