
                             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                  ej                        Z
y	)
z!Submit a SparkR job to a cluster.    )absolute_import)division)unicode_literals)spark_r)	submitterc                   &    e Zd ZdZed        Zd Zy)SparkRaj  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                     t         j                  j                  |        t        j                  j                  |        y N)r   
SparkRBaseArgsr   JobSubmitter)parsers    +lib/surface/dataproc/jobs/submit/spark_r.pyr   zSparkR.Args+   s*    F#'    c           	          t         j                  j                  ||| j                  | j	                  ||j
                        |       t        j                  j                  |||       y r   )r   r   ConfigureJobfiles_by_typeBuildLoggingConfigdriver_log_levelsr   r   )selfmessagesjobargss       r   r   zSparkR.ConfigureJob0   sV    ###t))$*@*@A4I ''#t<r   N)__name__
__module____qualname____doc__staticmethodr   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   