You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by sa...@apache.org on 2023/11/03 07:24:47 UTC
(pinot) branch master updated: Early release AcquireReleaseColumnsSegmentOperator during explain plan (#11945)
This is an automated email from the ASF dual-hosted git repository.
saurabhd336 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 18639b9443 Early release AcquireReleaseColumnsSegmentOperator during explain plan (#11945)
18639b9443 is described below
commit 18639b94438f87a1da4a8a36256a2a672e4cc8b4
Author: Saurabh Dubey <sa...@gmail.com>
AuthorDate: Fri Nov 3 12:54:42 2023 +0530
Early release AcquireReleaseColumnsSegmentOperator during explain plan (#11945)
Co-authored-by: Saurabh Dubey <sa...@Saurabhs-MacBook-Pro.local>
---
pinot-core/src/main/java/org/apache/pinot/core/common/Operator.java | 4 ++++
.../pinot/core/operator/AcquireReleaseColumnsSegmentOperator.java | 5 +++++
2 files changed, 9 insertions(+)
diff --git a/pinot-core/src/main/java/org/apache/pinot/core/common/Operator.java b/pinot-core/src/main/java/org/apache/pinot/core/common/Operator.java
index b6abbcb266..760074538b 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/common/Operator.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/common/Operator.java
@@ -51,6 +51,9 @@ public interface Operator<T extends Block> {
default void prepareForExplainPlan(ExplainPlanRows explainPlanRows) {
}
+ default void postExplainPlan(ExplainPlanRows explainPlanRows) {
+ }
+
default void explainPlan(ExplainPlanRows explainPlanRows, int[] globalId, int parentId) {
prepareForExplainPlan(explainPlanRows);
String explainPlanString = toExplainString();
@@ -66,6 +69,7 @@ public interface Operator<T extends Block> {
child.explainPlan(explainPlanRows, globalId, parentId);
}
}
+ postExplainPlan(explainPlanRows);
}
/**
diff --git a/pinot-core/src/main/java/org/apache/pinot/core/operator/AcquireReleaseColumnsSegmentOperator.java b/pinot-core/src/main/java/org/apache/pinot/core/operator/AcquireReleaseColumnsSegmentOperator.java
index 2b72292431..0f535b7806 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/operator/AcquireReleaseColumnsSegmentOperator.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/operator/AcquireReleaseColumnsSegmentOperator.java
@@ -92,6 +92,11 @@ public class AcquireReleaseColumnsSegmentOperator extends BaseOperator<BaseResul
materializeChildOperator();
}
+ @Override
+ public void postExplainPlan(ExplainPlanRows explainPlanRows) {
+ release();
+ }
+
@Override
public String toExplainString() {
return EXPLAIN_NAME;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org