Sha256: 8ecd49bd8fc8546054b8b9752a3a9441cd355158c18f4eac43067716e3eef56c
Contents?: true
Size: 945 Bytes
Versions: 12
Compression:
Stored size: 945 Bytes
Contents
package org.embulk.input.s3;
import com.google.common.base.Optional;
import com.amazonaws.services.s3.AmazonS3Client;
import org.embulk.config.Config;
import org.embulk.config.ConfigDefault;
import org.embulk.input.s3.AbstractS3FileInputPlugin;
public class S3FileInputPlugin
extends AbstractS3FileInputPlugin
{
public interface S3PluginTask
extends PluginTask
{
@Config("endpoint")
@ConfigDefault("null")
public Optional<String> getEndpoint();
}
@Override
protected Class<? extends PluginTask> getTaskClass()
{
return S3PluginTask.class;
}
@Override
protected AmazonS3Client newS3Client(PluginTask task)
{
S3PluginTask t = (S3PluginTask) task;
AmazonS3Client client = super.newS3Client(t);
if (t.getEndpoint().isPresent()) {
client.setEndpoint(t.getEndpoint().get());
}
return client;
}
}
Version data entries
12 entries across 12 versions & 1 rubygems