parameters: (self, cluster_size, num_coordinators, use_exclusive_coordinators,
                       start_idx=0)
docstring: Start 'cluster_size' impalad instances. The first 'num_coordinator' instances will
        act as coordinators. 'use_exclusive_coordinators' specifies whether the coordinators
        will only execute coordinator fragments.
docstring_summary: Start 'cluster_size' impalad instances. The first 'num_coordinator' instances will
        act as coordinators. 'use_exclusive_coordinators' specifies whether the coordinators
        will only execute coordinator fragments.
docstring_tokens: Start cluster_size impalad instances . The first num_coordinator instances will act as coordinators . use_exclusive_coordinators specifies whether the coordinators will only execute coordinator fragments .
function: def start_impalads(self, cluster_size, num_coordinators, use_exclusive_coordinators,
                       start_idx=0):
      """Start 'cluster_size' impalad instances. The first 'num_coordinator' instances will
        act as coordinators. 'use_exclusive_coordinators' specifies whether the coordinators
        will only execute coordinator fragments."""
      if cluster_size == 0:
        # No impalad instances should be started.
        return
  
      # The current TCP port allocation of the minicluster allows up to 10 impalads before
      # the backend port (25000 + idx) will collide with the statestore (25010).
      assert start_idx + cluster_size <= 10, "Must not start more than 10 impalads"
  
      impalad_arg_lists = build_impalad_arg_lists(
          cluster_size, num_coordinators, use_exclusive_coordinators, remap_ports=True,
          start_idx=start_idx)
      assert cluster_size == len(impalad_arg_lists)
      for i in xrange(start_idx, start_idx + cluster_size):
        service_name = impalad_service_name(i)
        LOG.info("Starting Impala Daemon logging to {log_dir}/{service_name}.INFO".format(
            log_dir=options.log_dir, service_name=service_name))
        output_file = os.path.join(
            options.log_dir, "{service_name}-out.log".format(service_name=service_name))
        run_daemon_with_options("impalad", impalad_arg_lists[i - start_idx],
            jvm_debug_port=DEFAULT_IMPALAD_JVM_DEBUG_PORT + i, output_file=output_file)
function_tokens: def start_impalads ( self , cluster_size , num_coordinators , use_exclusive_coordinators , start_idx = 0 ) : if cluster_size == 0 : # No impalad instances should be started. return # The current TCP port allocation of the minicluster allows up to 10 impalads before # the backend port (25000 + idx) will collide with the statestore (25010). assert start_idx + cluster_size <= 10 , "Must not start more than 10 impalads" impalad_arg_lists = build_impalad_arg_lists ( cluster_size , num_coordinators , use_exclusive_coordinators , remap_ports = True , start_idx = start_idx ) assert cluster_size == len ( impalad_arg_lists ) for i in xrange ( start_idx , start_idx + cluster_size ) : service_name = impalad_service_name ( i ) LOG . info ( "Starting Impala Daemon logging to {log_dir}/{service_name}.INFO" . format ( log_dir = options . log_dir , service_name = service_name ) ) output_file = os . path . join ( options . log_dir , "{service_name}-out.log" . format ( service_name = service_name ) ) run_daemon_with_options ( "impalad" , impalad_arg_lists [ i - start_idx ] , jvm_debug_port = DEFAULT_IMPALAD_JVM_DEBUG_PORT + i , output_file = output_file )