HappenLee commented on code in PR #59591:
URL: https://github.com/apache/doris/pull/59591#discussion_r2786091838
##########
be/src/pipeline/dependency.h:
##########
@@ -628,6 +628,34 @@ struct HashJoinSharedState : public JoinSharedState {
// local filter will always be applied, and in filter could guarantee
precise filtering
// ATTN: we should disable always_true logic for in filter when we set
this flag
bool left_semi_direct_return = false;
+
+ // ASOF JOIN specific fields
+ // Whether the inequality is >= or > (true) vs <= or < (false)
+ bool asof_inequality_is_greater = true;
+ // Whether the inequality is strict (> or <) vs non-strict (>= or <=)
+ bool asof_inequality_is_strict = false;
+
+ // ASOF JOIN pre-sorted index for O(log K) lookup per probe row
+ // Stores row_index per bucket, sorted by ASOF column value using
compare_at in probe phase
+ struct AsofEntry {
+ uint32_t row_index; // Build row index (1-based, 0 = invalid)
+ };
+ struct AsofBucketIndex {
+ // Entries sorted by asof_value (ascending for >= / >, descending for
<= / <)
+ std::vector<AsofEntry> entries;
+ bool valid = false;
Review Comment:
what case the is invalid
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
