hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

The datahub message for adaptive join is occupying a placeholder on the master branch.

Browse Source
This commit is contained in:
obdev 2024-09-18 06:54:43 +00:00 committed by ob-robot
parent f3b787f843
commit cd4968488a
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/dtl/ob_dtl_basic_channel.h
View File

@ -113,6 +113,8 @@ static DtlWriterType msg_writer_map[] =
CONTROL_WRITER, // DH_RD_WINFUNC_PX_WHOLE_MSG
CONTROL_WRITER, // DH_JOIN_FILTER_COUNT_ROW_PIECE_MSG,
CONTROL_WRITER, // DH_JOIN_FILTER_COUNT_ROW_WHOLE_MSG,
MAX_WRITER, // DH_STATISTICS_COLLECTOR_PIECE_MSG, placeholder
MAX_WRITER, // DH_STATISTICS_COLLECTOR_WHOLE_MSG, placeholder
};
static_assert(ARRAYSIZEOF(msg_writer_map) == ObDtlMsgType::MAX, "invalid ms_writer_map size");

2
src/sql/dtl/ob_dtl_msg_type.h
View File

@ -59,6 +59,8 @@ enum ObDtlMsgType {
DH_RD_WINFUNC_PX_WHOLE_MSG,
DH_JOIN_FILTER_COUNT_ROW_PIECE_MSG,
DH_JOIN_FILTER_COUNT_ROW_WHOLE_MSG,
DH_STATISTICS_COLLECTOR_PIECE_MSG, // 50 // placeholder
DH_STATISTICS_COLLECTOR_WHOLE_MSG, // placeholder
MAX
};