in src/main/java/org/apache/sdap/ningester/writer/S3Store.java [45:66]
public void saveData(List<? extends NexusTile> nexusTiles) {
for (NexusTile tile : nexusTiles) {
String tileId = getTileId(tile);
byte[] tileData = getTileData(tile);
Long contentLength = (long) tileData.length;
InputStream stream = new ByteArrayInputStream(tileData);
ObjectMetadata meta = new ObjectMetadata();
meta.setContentLength(contentLength);
try {
s3.putObject(new PutObjectRequest(bucketName, tileId, stream, meta));
} catch (AmazonServiceException ase) {
throw new DataStoreException("Caught an AmazonServiceException, which means your request made it "
+ "to Amazon S3, but was rejected with an error response for some reason.", ase);
} catch (AmazonClientException ace) {
throw new DataStoreException("Caught an AmazonClientException, which means the client encountered "
+ "a serious internal problem while trying to communicate with S3, "
+ "such as not being able to access the network.", ace);
}
}
}