Method GetNextInstanceId

be/src/runtime/data-stream-test.cc:366–374

Create an instance id and add it to dest_

  // Create an instance id and add it to dest_
  void GetNextInstanceId(TUniqueId* instance_id) {
    PlanFragmentDestinationPB* dest = dest_.Add();
    *dest->mutable_fragment_instance_id() = next_instance_id_;
    *dest->mutable_address() = MakeNetworkAddressPB("localhost", FLAGS_port, backend_id_,
        exec_env_->rpc_mgr()->GetUdsAddressUniqueId());
    *dest->mutable_krpc_backend() = krpc_address_;
    UniqueIdPBToTUniqueId(next_instance_id_, instance_id);
    next_instance_id_.set_lo(next_instance_id_.lo() + 1);
  }

  // RowDescriptor to mimic "select bigint_col from alltypesagg", except the slot
  // isn't nullable