Skip to content

Conversation

@yiguolei
Copy link
Contributor

@yiguolei yiguolei commented Aug 9, 2019

  1. Check all tablet using partition tablet map during publish version.
  2. Add eco mode meta sync interface.

3, // thread num
10000, // queue size
10, // batch size
boost::bind<void>(boost::mem_fn(&TabletSyncService::_fetch_rowset_meta_thread), this, _1));
Copy link
Contributor

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

Choose a reason for hiding this comment

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

Signature


namespace doris {


Copy link
Contributor

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

Choose a reason for hiding this comment

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

pull_tablet_pool

RowsetMetaPB rowset_meta_pb;
std::shared_ptr<std::promise<OLAPStatus>> pro;
bool operator< (const PushRowsetMetaTask& o) const {
return priority < o.priority;
Copy link
Contributor

Choose a reason for hiding this comment

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

two tab

bool load_data;
std::shared_ptr<std::promise<OLAPStatus>> pro;
bool operator< (const FetchTabletMetaTask& o) const {
return priority < o.priority;
Copy link
Contributor

Choose a reason for hiding this comment

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

two tab

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

Choose a reason for hiding this comment

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

put in together

@chaoyli chaoyli merged commit cc7a2a3 into apache:master Aug 14, 2019
swjtu-zhanglei pushed a commit to swjtu-zhanglei/incubator-doris that referenced this pull request Jul 25, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants