summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/window_function/window_function_integral.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/window_function/window_function_integral.h')
-rw-r--r--src/mongo/db/pipeline/window_function/window_function_integral.h7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/mongo/db/pipeline/window_function/window_function_integral.h b/src/mongo/db/pipeline/window_function/window_function_integral.h
index 6516ba6ca16..10b970a4c5f 100644
--- a/src/mongo/db/pipeline/window_function/window_function_integral.h
+++ b/src/mongo/db/pipeline/window_function/window_function_integral.h
@@ -45,7 +45,8 @@ public:
}
explicit WindowFunctionIntegral(ExpressionContext* const expCtx,
- boost::optional<long long> outputUnitMillis = boost::none)
+ boost::optional<long long> outputUnitMillis = boost::none,
+ bool isNonremovable = false)
: WindowFunctionState(expCtx), _integral(expCtx), _outputUnitMillis(outputUnitMillis) {
_memUsageBytes = sizeof(*this);
}
@@ -61,6 +62,9 @@ public:
_values.clear();
_nanCount = 0;
_integral.reset();
+ // AccumulatorIntegral's reset() depends on the fact that WindowFunctionIntegral's reset()
+ // will set '_memUsageBytes' to sizeof(*this). If you want to reset '_memUsageBytes' to
+ // other value, please update AccumulatorIntegral's reset() as well.
_memUsageBytes = sizeof(*this);
}
@@ -91,6 +95,7 @@ private:
std::deque<Value> _values;
boost::optional<long long> _outputUnitMillis;
int _nanCount = 0;
+ bool isNonremovable = false;
};
} // namespace mongo