
    Y                     n    S r SSKJr  SSKJr  SSKJr  SSKJr  SSKJr   " S S\R                  5      r
g	)
z5The command group for submitting cloud dataproc jobs.    )absolute_import)division)unicode_literals)base)flagsc                   (    \ rS rSrSr\S 5       rSrg)Submit   a  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                     U R                  SSSS9  [        R                  " U 5        [        R                  R                  U 5        U R                  SSS9  g )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ArgsSubmit.Args:   s^     D  F
 
OO'
-  /     N)__name__
__module____qualname____firstlineno____doc__staticmethodr   __static_attributes__r   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   