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);