-
Notifications
You must be signed in to change notification settings - Fork 328
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat: consolidate Insert request related partitioning and distributed processing operations into Inserter #2346
feat: consolidate Insert request related partitioning and distributed processing operations into Inserter #2346
Conversation
Signed-off-by: Zhenchi <[email protected]>
Codecov Report
Additional details and impacted files@@ Coverage Diff @@
## migrate-region-server #2346 +/- ##
========================================================
Coverage ? 77.54%
========================================================
Files ? 714
Lines ? 113737
Branches ? 0
========================================================
Hits ? 88192
Misses ? 25545
Partials ? 0 |
…ted mode Signed-off-by: Zhenchi <[email protected]>
Signed-off-by: Zhenchi <[email protected]>
Signed-off-by: Zhenchi <[email protected]>
Signed-off-by: Zhenchi <[email protected]>
Signed-off-by: Zhenchi <[email protected]>
Signed-off-by: Zhenchi <[email protected]>
Signed-off-by: Zhenchi <[email protected]>
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.
LGTM
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.
Great job!
Signed-off-by: Zhenchi <[email protected]>
Signed-off-by: Zhenchi <[email protected]>
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.
LGTM
6957fd1
… processing operations into Inserter (#2346) * refactor: RegionRequest as param of RegionRequestHandler.handle Signed-off-by: Zhenchi <[email protected]> * feat: partition insert & delete reqs for both standalone and distributed mode Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> * fix: wrong function nameg Signed-off-by: Zhenchi <[email protected]> * feat: do request in inserter & deleter Signed-off-by: Zhenchi <[email protected]> * feat: remove RegionRequestHandler.handle Signed-off-by: Zhenchi <[email protected]> * refactor: rename table_creator Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> * refactor: address comments Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> --------- Signed-off-by: Zhenchi <[email protected]>
… processing operations into Inserter (#2346) * refactor: RegionRequest as param of RegionRequestHandler.handle Signed-off-by: Zhenchi <[email protected]> * feat: partition insert & delete reqs for both standalone and distributed mode Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> * fix: wrong function nameg Signed-off-by: Zhenchi <[email protected]> * feat: do request in inserter & deleter Signed-off-by: Zhenchi <[email protected]> * feat: remove RegionRequestHandler.handle Signed-off-by: Zhenchi <[email protected]> * refactor: rename table_creator Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> * refactor: address comments Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> --------- Signed-off-by: Zhenchi <[email protected]>
… processing operations into Inserter (#2346) * refactor: RegionRequest as param of RegionRequestHandler.handle Signed-off-by: Zhenchi <[email protected]> * feat: partition insert & delete reqs for both standalone and distributed mode Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> * fix: wrong function nameg Signed-off-by: Zhenchi <[email protected]> * feat: do request in inserter & deleter Signed-off-by: Zhenchi <[email protected]> * feat: remove RegionRequestHandler.handle Signed-off-by: Zhenchi <[email protected]> * refactor: rename table_creator Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> * refactor: address comments Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> --------- Signed-off-by: Zhenchi <[email protected]>
… processing operations into Inserter (GreptimeTeam#2346) * refactor: RegionRequest as param of RegionRequestHandler.handle Signed-off-by: Zhenchi <[email protected]> * feat: partition insert & delete reqs for both standalone and distributed mode Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> * fix: wrong function nameg Signed-off-by: Zhenchi <[email protected]> * feat: do request in inserter & deleter Signed-off-by: Zhenchi <[email protected]> * feat: remove RegionRequestHandler.handle Signed-off-by: Zhenchi <[email protected]> * refactor: rename table_creator Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> * refactor: address comments Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> --------- Signed-off-by: Zhenchi <[email protected]>
… processing operations into Inserter (GreptimeTeam#2346) * refactor: RegionRequest as param of RegionRequestHandler.handle Signed-off-by: Zhenchi <[email protected]> * feat: partition insert & delete reqs for both standalone and distributed mode Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> * fix: wrong function nameg Signed-off-by: Zhenchi <[email protected]> * feat: do request in inserter & deleter Signed-off-by: Zhenchi <[email protected]> * feat: remove RegionRequestHandler.handle Signed-off-by: Zhenchi <[email protected]> * refactor: rename table_creator Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> * refactor: address comments Signed-off-by: Zhenchi <[email protected]> * chore: nit change Signed-off-by: Zhenchi <[email protected]> --------- Signed-off-by: Zhenchi <[email protected]>
I hereby agree to the terms of the GreptimeDB CLA
same for Delete requests
What's changed and what's your intention?
frontend::instance::distributed::{inserter|deleter}
Partitioner
for all{Insert|Delete}
request converters to partition requests into region requestshandle_table_insert
andhandle_statement_insert
tofrontend::insert::Inserter
handle_table_insert
tofrontend::delete::Deleter
handle
inRegionServerHandler
frontend::insert::Inserter
andfrontend::delete::Deleter
internally send distributed requestsChecklist
Refer to a related PR or issue link (optional)