return new Path(ccHdfsPath + s3key.toString());
}
private AmazonS3Client newS3Client() {
AmazonS3Client s3Client = new AmazonS3Client(new BasicAWSCredentials(awsAccessKeyId, awsSecretAccessKey));
s3Client.addRequestHandler(new AbstractRequestHandler() {
public void beforeRequest(Request<?> request) {
request.addHeader("x-amz-request-payer", "requester");
}
});
return s3Client;