create amazons3 client using aws credentials concode_field_sep String bucketName concode_elem_sep Logger LOG concode_elem_sep Map<String,S3InitiateFileUploadOperator.UploadFileMetadata> fileMetadatas concode_elem_sep DefaultInputPort<S3BlockUploadOperator.UploadBlockMetadata> uploadMetadataInput concode_elem_sep DefaultInputPort<S3InitiateFileUploadOperator.UploadFileMetadata> filesMetadataInput concode_elem_sep WindowDataManager windowDataManager concode_elem_sep String secretAccessKey concode_elem_sep String endPoint concode_elem_sep long currentWindowId concode_elem_sep String accessKey concode_elem_sep AmazonS3 s3Client concode_elem_sep List<String> uploadedFiles concode_elem_sep Map<String,List<PartETag>> uploadParts concode_field_sep void beforeCheckpoint concode_elem_sep void setEndPoint concode_elem_sep void process concode_elem_sep void process concode_elem_sep void committed concode_elem_sep void verifyAndEmitFileMerge concode_elem_sep String getSecretAccessKey concode_elem_sep void endWindow concode_elem_sep void checkpointed concode_elem_sep void setBucketName concode_elem_sep void beginWindow concode_elem_sep String getEndPoint concode_elem_sep void setAccessKey concode_elem_sep void processFileMetadata concode_elem_sep void setup concode_elem_sep String getAccessKey concode_elem_sep void setSecretAccessKey concode_elem_sep void teardown concode_elem_sep void processUploadBlock concode_elem_sep String getBucketName
AmazonS3 function ( ) { AmazonS3 loc0 = new AmazonS3Client ( new BasicAWSCredentials ( accessKey , secretAccessKey ) ) ; if ( endPoint != null ) { loc0 . setEndpoint ( endPoint ) ; } return loc0 ; }