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 <[email protected]>
AuthorDate: Fri Nov 3 12:54:42 2023 +0530
Early release AcquireReleaseColumnsSegmentOperator during explain plan
(#11945)
Co-authored-by: Saurabh Dubey <[email protected]>
---
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: [email protected]
For additional commands, e-mail: [email protected]
