Method SetIntermediateAggregation

be/src/runtime/runtime-filter.cc:94–101

}

void RuntimeFilter::SetIntermediateAggregation(bool is_intermediate_aggregator,
    std::string intermediate_krpc_hostname, NetworkAddressPB intermediate_krpc_backend) {
  DCHECK(!intermediate_krpc_hostname.empty());
  DCHECK(IsResolvedAddress(intermediate_krpc_backend));
  is_intermediate_aggregator_ = is_intermediate_aggregator;
  intermediate_krpc_hostname_ = move(intermediate_krpc_hostname);
  intermediate_krpc_backend_ = move(intermediate_krpc_backend);
}