| 95 | const int64_t FileSplitGeneratorSpec::DEFAULT_BLOCK_SIZE = 1 << 20; |
| 96 | |
| 97 | ClusterMembershipMgr::BeDescSharedPtr BuildBackendDescriptor(const Host& host) { |
| 98 | auto be_desc = make_shared<BackendDescriptorPB>(); |
| 99 | be_desc->mutable_address()->set_hostname(host.ip); |
| 100 | be_desc->mutable_address()->set_port(host.be_port); |
| 101 | be_desc->set_ip_address(host.ip); |
| 102 | be_desc->set_is_coordinator(host.is_coordinator); |
| 103 | be_desc->set_is_executor(host.is_executor); |
| 104 | be_desc->set_is_quiescing(false); |
| 105 | be_desc->set_admit_mem_limit(GIGABYTE); |
| 106 | ExecutorGroupDescPB* exec_desc = be_desc->add_executor_groups(); |
| 107 | exec_desc->set_name(ImpalaServer::DEFAULT_EXECUTOR_GROUP_NAME); |
| 108 | exec_desc->set_min_size(1); |
| 109 | return be_desc; |
| 110 | } |
| 111 | |
| 112 | int Cluster::AddHost(bool has_backend, bool has_datanode, bool is_executor) { |
| 113 | int host_idx = hosts_.size(); |
no test coverage detected