Untitled
Anonymous
plain_text
05/23/2024 2:54 AM
1.0 KB
18
Indexable
private static Optional<S3ObjectSummary> findLatestCSVFile(AmazonS3 s3Client) {
ListObjectsV2Request req = new ListObjectsV2Request().withBucketName(BUCKET_NAME).withPrefix(PREFIX);
ListObjectsV2Result result;
List<S3ObjectSummary> csvFiles;
do {
result = s3Client.listObjectsV2(req);
csvFiles = result.getObjectSummaries().stream()
.filter(obj -> obj.getKey().endsWith(".csv"))
.collect(Collectors.toList());
String token = result.getNextContinuationToken();
req.setContinuationToken(token);
} while (result.isTruncated());
return csvFiles.stream()
.max(Comparator.comparing(S3ObjectSummary::getLastModified));
}Editor is loading...
Leave a Comment