maytasm commented on code in PR #19141:
URL: https://github.com/apache/druid/pull/19141#discussion_r2927792099
##########
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/TemporaryStorageFileLimitException.java:
##########
@@ -17,42 +17,16 @@
* under the License.
*/
-package org.apache.druid.storage.s3;
+package org.apache.druid.query.groupby.epinephelinae;
-import software.amazon.awssdk.services.s3.model.S3Object;
+import org.apache.druid.java.util.common.StringUtils;
-/**
- * Pairs an {@link S3Object} with its bucket name.
- * In AWS SDK v2, {@link S3Object} does not carry the bucket name, so callers
that need it must track it separately.
- */
-public class S3ObjectWithBucket
-{
- private final String bucket;
- private final S3Object s3Object;
-
- public S3ObjectWithBucket(String bucket, S3Object s3Object)
- {
- this.bucket = bucket;
- this.s3Object = s3Object;
- }
-
- public String getBucket()
- {
- return bucket;
- }
+import java.io.IOException;
- public String getKey()
- {
- return s3Object.key();
- }
-
- public long getSize()
- {
- return s3Object.size();
- }
-
- public S3Object getS3Object()
+public class TemporaryStorageFileLimitException extends IOException
+{
+ public TemporaryStorageFileLimitException(final int fileCount)
{
- return s3Object;
+ super(StringUtils.format("Cannot write to disk, hit file count limit of
%,d.", fileCount));
Review Comment:
Done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
