external/aws/src/main/java/com/digitalpebble/stormcrawler/aws/s3/AbstractS3CacheBolt.java
public static AmazonS3Client getS3Client(Map conf) {
        AWSCredentialsProvider provider = new DefaultAWSCredentialsProviderChain();
        AWSCredentials credentials = provider.getCredentials();
        ClientConfiguration config = new ClientConfiguration();

        AmazonS3Client client = new AmazonS3Client(credentials, config);

        String regionName = ConfUtils.getString(conf, REGION);
        if (StringUtils.isNotBlank(regionName)) {
            client.setRegion(RegionUtils.getRegion(regionName));
        }

        String endpoint = ConfUtils.getString(conf, ENDPOINT);
        if (StringUtils.isNotBlank(endpoint)) {
            client.setEndpoint(endpoint);
        }
        return client;
    }
public static AmazonS3Client getS3Client(Map conf) {
        AWSCredentialsProvider provider = new DefaultAWSCredentialsProviderChain();
        AWSCredentials credentials = provider.getCredentials();
        ClientConfiguration config = new ClientConfiguration();

        AmazonS3Client client = new AmazonS3Client(credentials, config);

        String regionName = ConfUtils.getString(conf, REGION);
        if (StringUtils.isNotBlank(regionName)) {
            client.setRegion(RegionUtils.getRegion(regionName));
        }

        String endpoint = ConfUtils.getString(conf, ENDPOINT);
        if (StringUtils.isNotBlank(endpoint)) {
            client.setEndpoint(endpoint);
        }
        return client;
    }
public static AmazonS3Client getS3Client ( Map conf ) { AWSCredentialsProvider provider = new DefaultAWSCredentialsProviderChain ( ) ; AWSCredentials credentials = provider . getCredentials ( ) ; ClientConfiguration config = new ClientConfiguration ( ) ; AmazonS3Client client = new AmazonS3Client ( credentials , config ) ; String regionName = ConfUtils . getString ( conf , REGION ) ; if ( StringUtils . isNotBlank ( regionName ) ) { client . setRegion ( RegionUtils . getRegion ( regionName ) ) ; } String endpoint = ConfUtils . getString ( conf , ENDPOINT ) ; if ( StringUtils . isNotBlank ( endpoint ) ) { client . setEndpoint ( endpoint ) ; } return client ; }
Returns an S3 client given the configuration *
Returns an S3 client given the configuration *