Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

caching/maxResultSize/batch/allowPartialResults & checkExists/existsAll optimize#2106

Open
HexyinUESTC wants to merge 5 commits intooceanbase:masterfrom
HexyinUESTC:master
Open

caching/maxResultSize/batch/allowPartialResults & checkExists/existsAll optimize#2106
HexyinUESTC wants to merge 5 commits intooceanbase:masterfrom
HexyinUESTC:master

Conversation

@HexyinUESTC
Copy link

@HexyinUESTCHexyinUESTC commentedAug 28, 2024
edited
Loading

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

@HexyinUESTCHexyinUESTCforce-pushed themaster branch 2 times, most recently from019836d tod64ffb6CompareAugust 29, 2024 06:20
@shenyunlong
Copy link
Contributor

The PR's title should in English.

@HexyinUESTCHexyinUESTC changed the titlecaching/maxResultSize/batch/allowPartialResults & checkExists/existsAll 优化caching/maxResultSize/batch/allowPartialResults & checkExists/existsAll optimizeAug 29, 2024
@HexyinUESTCHexyinUESTCforce-pushed themaster branch 2 times, most recently from831a194 to281cd8eCompareAugust 30, 2024 07:42
init_properties(hbase_params, query);
}

bool ObHTableFilterOperator::reach_caching_limit(int num_of_row) {
Copy link
Contributor

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;
Copy link
Contributor

@shenyunlongshenyunlongAug 30, 2024
edited
Loading

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() {
Copy link
Contributor

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);
Copy link
Contributor

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();
Copy link
Contributor

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();
Copy link
Contributor

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();
Copy link
Contributor

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 {
Copy link
Contributor

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 {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others.Learn more.

Scope {
->
Scope
{

Sign up for freeto join this conversation on GitHub. Already have an account?Sign in to comment

Reviewers

1 more reviewer

@shenyunlongshenyunlongshenyunlong left review comments

Reviewers whose approvals may not affect merge requirements

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

2 participants

@HexyinUESTC@shenyunlong

Comments


[8]ページ先頭

©2009-2026 Movatter.jp