public void delete()

in src/main/java/com/epam/digital/data/platform/integration/ceph/service/impl/CephServiceS3Impl.java [141:150]


  public void delete(String cephBucketName, Set<String> keys) {
    log.info("Deleting files with keys {} from ceph bucket {}", keys, cephBucketName);
    assertBucketExists(cephAmazonS3, cephBucketName);
    executeRunnable(() -> {
      var keyVersions = keys.stream().map(KeyVersion::new).collect(Collectors.toList());
      var deleteObjectsRequest = new DeleteObjectsRequest(cephBucketName).withKeys(keyVersions);
      cephAmazonS3.deleteObjects(deleteObjectsRequest);
    });
    log.info("Files {} was deleted from ceph bucket {}", keys, cephBucketName);
  }