
                             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                  \R                  5      r
g	)
z!Submit a SparkR job to a cluster.    )absolute_import)division)unicode_literals)spark_r)	submitterc                   .    \ rS rSrSr\S 5       rS rSrg)SparkR   aZ  Submit a SparkR job to a cluster.

Submit a SparkR job to a cluster.

## EXAMPLES

To submit a SparkR job with a local script, run:

  $ {command} --cluster=my-cluster my_script.R

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

  $ {command} --cluster=my-cluster file:///.../my_script.R \
      -- gs://my_bucket/data.csv
c                     [         R                  R                  U 5        [        R                  R                  U 5        g N)r   
SparkRBaseArgsr   JobSubmitter)parsers    +lib/surface/dataproc/jobs/submit/spark_r.pyr   SparkR.Args+   s*    F#'    c           	          [         R                  R                  XU R                  U R	                  XR
                  5      U5        [        R                  R                  XU5        g r   )r   r   ConfigureJobfiles_by_typeBuildLoggingConfigdriver_log_levelsr   r   )selfmessagesjobargss       r   r   SparkR.ConfigureJob0   sP    ##t))*@*@A4I ''t<r    N)	__name__
__module____qualname____firstlineno____doc__staticmethodr   r   __static_attributes__r   r   r   r	   r	      s       ( (=r   r	   N)r#   
__future__r   r   r   (googlecloudsdk.command_lib.dataproc.jobsr   r   r   r   r	   r   r   r   <module>r(      s3     ( &  ' < >=W!7!7 =r   