gianm commented on code in PR #18926:
URL: https://github.com/apache/druid/pull/18926#discussion_r2706771935
##########
multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java:
##########
@@ -370,6 +371,20 @@ public static int getMaxPartitions(final QueryContext
queryContext)
return value;
}
+ public static int getMaxClusteredByColumns(final QueryContext queryContext)
+ {
+ final Integer value = queryContext.getInt(CTX_MAX_CLUSTERED_BY_COLUMNS);
+ if (value == null) {
+ return Limits.MAX_CLUSTERED_BY_COLUMNS;
+ }
+ if (value <= 0) {
+ throw DruidException.forPersona(DruidException.Persona.USER)
+ .ofCategory(DruidException.Category.INVALID_INPUT)
+ .build("%s must be a positive integer, got[%d]",
CTX_MAX_CLUSTERED_BY_COLUMNS, value);
Review Comment:
Updated this and also other occurrences in the same file.
##########
multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java:
##########
@@ -145,6 +145,7 @@ public class MultiStageQueryContext
public static final String CTX_MAX_INPUT_BYTES_PER_WORKER =
"maxInputBytesPerWorker";
public static final String CTX_MAX_INPUT_FILES_PER_WORKER =
"maxInputFilesPerWorker";
public static final String CTX_MAX_PARTITIONS = "maxPartitions";
+ public static final String CTX_MAX_CLUSTERED_BY_COLUMNS =
"maxClusteredByColumns";
Review Comment:
Added a comment.
--
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]
