
    Y                     n    d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ  G d dej                        Z
y	)
z5The command group for submitting cloud dataproc jobs.    )absolute_import)division)unicode_literals)base)flagsc                        e Zd ZdZed        Zy)Submita  Submit Dataproc jobs to execute on a cluster.

  Submit Dataproc jobs to execute on a cluster.

  ## EXAMPLES

  To submit a Hadoop MapReduce job, run:

    $ {command} hadoop --cluster my-cluster --jar my_jar.jar -- arg1 arg2

  To submit a Spark Scala or Java job, run:

    $ {command} spark --cluster my-cluster --jar my_jar.jar -- arg1 arg2

  To submit a PySpark job, run:

    $ {command} pyspark --cluster my-cluster my_script.py -- arg1 arg2

  To submit a Spark SQL job, run:

    $ {command} spark-sql --cluster my-cluster --file my_queries.q

  To submit a Pig job, run:

    $ {command} pig --cluster my-cluster --file my_script.pig

  To submit a Hive job, run:

    $ {command} hive --cluster my-cluster --file my_queries.q
  c                     | j                  ddd       t        j                  |        t        j                  j                  |        | j                  dd       y )Nz--idTz5Set the ID of the job, which is usually autogenerated)hiddenhelpz--bucketzXThe Cloud Storage bucket to stage files in. Defaults to the cluster's configured bucket.)r   )add_argumentr   AddRegionFlagr   
ASYNC_FLAGAddToParser)parsers    ,lib/surface/dataproc/jobs/submit/__init__.pyArgszSubmit.Args:   s^     D  F
 
OO'
-  /    N)__name__
__module____qualname____doc__staticmethodr    r   r   r	   r	      s    > / /r   r	   N)r   
__future__r   r   r   googlecloudsdk.callioper   #googlecloudsdk.command_lib.dataprocr   Groupr	   r   r   r   <module>r      s)     < &  ' ( 5//TZZ //r   