- Notifications
You must be signed in to change notification settings - Fork1.9k
caching/maxResultSize/batch/allowPartialResults & checkExists/existsAll optimize#2106
caching/maxResultSize/batch/allowPartialResults & checkExists/existsAll optimize#2106HexyinUESTC wants to merge 5 commits intooceanbase:masterfrom
Conversation
019836d tod64ffb6Compareshenyunlong commentedAug 29, 2024
The PR's title should in English. |
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
Uh oh!
There was an error while loading.Please reload this page.
831a194 to281cd8eCompareUh oh!
There was an error while loading.Please reload this page.
| init_properties(hbase_params, query); | ||
| } | ||
| bool ObHTableFilterOperator::reach_caching_limit(int num_of_row) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others.Learn more.
reach_caching_limit(int num_of_row) {
->
reach_caching_limit(int num_of_row)
{
| ObArray<ObObj> fake_row; | ||
| one_result_->reset(); | ||
| if (OB_FAIL(one_result_->add_row(fake_row))) { | ||
| ret = OB_ERR_ADD_INDEX; |
shenyunlongAug 30, 2024 • edited
Loading Uh oh!
There was an error while loading.Please reload this page.
edited
Uh oh!
There was an error while loading.Please reload this page.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others.Learn more.
retcode will be overwrite here
| return ret; | ||
| } | ||
| void ObHTableFilterOperator::check_exist_only() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others.Learn more.
this function seems useless
| ScannerContext::ScannerContext() | ||
| { | ||
| limits_.set_fields(limit_default_value_, limit_default_value_, limit_default_value_, LimitScope::Scope::BETWEEN_ROWS); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others.Learn more.
maybe it's better to use static const for default value
| bool ScannerContext::check_batch_limit(LimitScope checker_scope) | ||
| { | ||
| if (limits_.can_enforce_batch_from_scope(checker_scope) && limits_.get_batch() > 0) { | ||
| return progress_.get_batch() >= limits_.get_batch(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others.Learn more.
only one return is allowed
| bool ScannerContext::check_size_limit(LimitScope checker_scope) { | ||
| if (limits_.can_enforce_size_from_scope(checker_scope) && limits_.get_size() >0 ) { | ||
| return progress_.get_size() >= limits_.get_size(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others.Learn more.
only one return is allowed
| bool ScannerContext::check_time_limit(LimitScope checker_scope) | ||
| { | ||
| if (limits_.can_enforce_time_from_scope(checker_scope) && limits_.get_time() > 0) { | ||
| return progress_.get_time() >= limits_.get_time(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others.Learn more.
only one return is allowed
| }; | ||
| class LimitScope { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others.Learn more.
LimitScope {
->
LimitScope
{
| class LimitScope { | ||
| public: | ||
| enum class Scope { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others.Learn more.
Scope {
->
Scope
{
Uh oh!
There was an error while loading.Please reload this page.
Task Description
To be compatible with HBase 1.x
Solution Description
add limit caching/maxResultSize/batch/allowPartialResults and optimize checkExists/existsAll
Passed Regressions
Upgrade Compatibility
Other Information
Release Note