BiteTheDDDDt commented on code in PR #46181:
URL: https://github.com/apache/doris/pull/46181#discussion_r1926292587
##########
be/src/pipeline/exec/analytic_sink_operator.h:
##########
@@ -28,6 +28,37 @@ namespace doris {
namespace pipeline {
class AnalyticSinkOperatorX;
+struct BoundaryPose {
+ int64_t start = 0;
+ int64_t end = 0;
+ bool is_ended = false;
+ void remove_unused_rows(int64_t cnt) {
+ start -= cnt;
+ end -= cnt;
+ }
+};
+
+class PartitionStatistics {
+public:
+ void update(int64_t size) {
+ _count++;
+ _cumulative_size += size;
+ _average_size = _cumulative_size / _count;
+ }
+
+ void reset() {
+ _count = 0;
+ _cumulative_size = 0;
+ _average_size = 0;
+ }
+
+ bool is_high_cardinality() const { return _count > 16 && _average_size <
8; }
Review Comment:
better avoid use magic number
--
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: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
