-
Notifications
You must be signed in to change notification settings - Fork 3.7k
Check all tablet using partition tablet map during publish version #1619
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
Conversation
yiguolei
commented
Aug 9, 2019
- Check all tablet using partition tablet map during publish version.
- Add eco mode meta sync interface.
be/src/olap/tablet_sync_service.cpp
Outdated
| 3, // thread num | ||
| 10000, // queue size | ||
| 10, // batch size | ||
| boost::bind<void>(boost::mem_fn(&TabletSyncService::_fetch_rowset_meta_thread), this, _1)); |
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.
std::bind
| template <typename T> | ||
| class BatchProcessThreadPool { | ||
| public: | ||
| // Singnature of function that process task batch by batch not one by one |
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.
Signature
|
|
||
| namespace doris { | ||
|
|
||
|
|
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.
redundant empty line
| private: | ||
| BatchProcessThreadPool<FetchRowsetMetaTask>* _fetch_rowset_pool = nullptr; | ||
| BatchProcessThreadPool<PushRowsetMetaTask>* _push_rowset_pool = nullptr; | ||
| BatchProcessThreadPool<FetchTabletMetaTask>* _fetch_tablet_pool = nullptr; |
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.
pull_tablet_pool
be/src/olap/tablet_sync_service.h
Outdated
| RowsetMetaPB rowset_meta_pb; | ||
| std::shared_ptr<std::promise<OLAPStatus>> pro; | ||
| bool operator< (const PushRowsetMetaTask& o) const { | ||
| return priority < o.priority; |
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.
two tab
be/src/olap/tablet_sync_service.h
Outdated
| bool load_data; | ||
| std::shared_ptr<std::promise<OLAPStatus>> pro; | ||
| bool operator< (const FetchTabletMetaTask& o) const { | ||
| return priority < o.priority; |
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.
two tab
be/src/olap/tablet_sync_service.h
Outdated
| void _push_rowset_meta_thread(std::vector<PushRowsetMetaTask> tasks); | ||
| void _fetch_tablet_meta_thread(std::vector<FetchTabletMetaTask> tasks); | ||
| void _push_tablet_meta_thread(std::vector<PushTabletMetaTask> tasks); | ||
| public: |
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.
put in together