This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new c5095c4164 fix custom property naming (#11675)
c5095c4164 is described below
commit c5095c41644f64d5dde080e4ed9b67336f63831a
Author: Rong Rong <[email protected]>
AuthorDate: Mon Sep 25 13:01:07 2023 -0700
fix custom property naming (#11675)
---
.../pinot/query/runtime/operator/MultistageGroupByExecutor.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/MultistageGroupByExecutor.java
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/MultistageGroupByExecutor.java
index 075e24282f..7b4cb28071 100644
---
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/MultistageGroupByExecutor.java
+++
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/MultistageGroupByExecutor.java
@@ -96,7 +96,7 @@ public class MultistageGroupByExecutor {
_groupKeyToIdMap.defaultReturnValue(GroupKeyGenerator.INVALID_ID);
}
- private int getNumGroupsLimit(Map<String, String> customProperties,
@Nullable AbstractPlanNode.NodeHint nodeHint) {
+ private int getNumGroupsLimit(Map<String, String> opChainMetadata, @Nullable
AbstractPlanNode.NodeHint nodeHint) {
if (nodeHint != null) {
Map<String, String> aggregateOptions =
nodeHint._hintOptions.get(PinotHintOptions.AGGREGATE_HINT_OPTIONS);
if (aggregateOptions != null) {
@@ -106,11 +106,11 @@ public class MultistageGroupByExecutor {
}
}
}
- Integer numGroupsLimit =
QueryOptionsUtils.getNumGroupsLimit(customProperties);
+ Integer numGroupsLimit =
QueryOptionsUtils.getNumGroupsLimit(opChainMetadata);
return numGroupsLimit != null ? numGroupsLimit :
InstancePlanMakerImplV2.DEFAULT_NUM_GROUPS_LIMIT;
}
- private int getMaxInitialResultHolderCapacity(Map<String, String>
customProperties,
+ private int getMaxInitialResultHolderCapacity(Map<String, String>
opChainMetadata,
@Nullable AbstractPlanNode.NodeHint nodeHint) {
if (nodeHint != null) {
Map<String, String> aggregateOptions =
nodeHint._hintOptions.get(PinotHintOptions.AGGREGATE_HINT_OPTIONS);
@@ -122,7 +122,7 @@ public class MultistageGroupByExecutor {
}
}
}
- Integer maxInitialResultHolderCapacity =
QueryOptionsUtils.getMaxInitialResultHolderCapacity(customProperties);
+ Integer maxInitialResultHolderCapacity =
QueryOptionsUtils.getMaxInitialResultHolderCapacity(opChainMetadata);
return maxInitialResultHolderCapacity != null ?
maxInitialResultHolderCapacity
: InstancePlanMakerImplV2.DEFAULT_MAX_INITIAL_RESULT_HOLDER_CAPACITY;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
