
    #	                         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KJ	r	   " S S	\R                  \	R                  5      rg
)z Submit a Spark job to a cluster.    )absolute_import)division)unicode_literals)util)spark)	submitterc                   .    \ rS rSrSr\S 5       rS rSrg)Spark   a  Submit a Spark job to a cluster.

Submit a Spark job to a cluster.

## EXAMPLES

To submit a Spark job that runs the main class of a jar, run:

  $ {command} --cluster=my-cluster --region=us-central1 --jar=my_jar.jar -- arg1 arg2

To submit a Spark job that runs a specific class of a jar, run:

  $ {command} --cluster=my-cluster --region=us-central1 --class=org.my.main.Class \
      --jars=my_jar1.jar,my_jar2.jar -- arg1 arg2

To submit a Spark job that runs a jar that is already on the cluster, run:

  $ {command} --cluster=my-cluster --region=us-central1 \
      --class=org.apache.spark.examples.SparkPi \
      --jars=file:///usr/lib/spark/examples/jars/spark-examples.jar \
      -- 1000
c                     [         R                  R                  U 5        [        R                  R                  U 5        U R                  SSS9n[        R                  " U5        g )NT)requiredmutex)r   	SparkBaseArgsr   JobSubmitteradd_argument_groupr   AddJvmDriverFlags)parserdriver_groups     )lib/surface/dataproc/jobs/submit/spark.pyr   
Spark.Args5   sK    	OO ',,d$,GL<(    c           	          [         R                  R                  XU R                  U R	                  XR
                  5      U5        [        R                  R                  XU5        g )N)r   r   ConfigureJobfiles_by_typeBuildLoggingConfigdriver_log_levelsr   r   )selfmessagesjobargss       r   r   Spark.ConfigureJob<   sR    	OO  0B0B!%!8!8%-/E/E"GHLN ''t<r    N)	__name__
__module____qualname____firstlineno____doc__staticmethodr   r   __static_attributes__r#   r   r   r
   r
      s     0 ) )=r   r
   N)r(   
__future__r   r   r   googlecloudsdk.api_lib.dataprocr   (googlecloudsdk.command_lib.dataproc.jobsr   r   r   r   r
   r#   r   r   <module>r.      s4     ' &  ' 0 : >%=EOOY33 %=r   