diff --git a/src/main/java/org/embulk/input/s3/S3FileInputPlugin.java b/src/main/java/org/embulk/input/s3/S3FileInputPlugin.java index 99a59d5..1f8b6e0 100644 --- a/src/main/java/org/embulk/input/s3/S3FileInputPlugin.java +++ b/src/main/java/org/embulk/input/s3/S3FileInputPlugin.java @@ -134,6 +134,10 @@ public interface PluginTask @Config("region") @ConfigDefault("null") Optional getRegion(); + + @Config("path_style_access") + @ConfigDefault("false") + boolean getPathStyleAccess(); } @Override @@ -447,11 +451,13 @@ private AmazonS3 newS3Client(final PluginTask task) { Optional endpoint = task.getEndpoint(); Optional region = task.getRegion(); + Boolean pathStyleAccess = task.getPathStyleAccess(); final AmazonS3ClientBuilder builder = AmazonS3ClientBuilder .standard() .withCredentials(getCredentialsProvider(task)) - .withClientConfiguration(getClientConfiguration(task)); + .withClientConfiguration(getClientConfiguration(task)) + .withPathStyleAccessEnabled(pathStyleAccess); // Favor the `endpoint` configuration, then `region`, if both are absent then `s3.amazonaws.com` will be used. if (endpoint.isPresent()) {