
                            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	 ddl
mZ ddl
mZ  e	j                  e	j                  j                  e	j                  j                          G d	 d
e	j"                               Zy)zSubmit a SparkR batch job.    )absolute_import)division)unicode_literals)dataproc)base)batch_submitter)sparkr_batch_factoryc                   .    e Zd ZdZddiZed        Zd Zy)SparkRzSubmit a Spark R batch job.EXAMPLESz          To submit a Spark R batch job running "my-main-r.r" script and upload it to "gs://my-bucket", run:

            $ {command} my-main-r.r --deps-bucket=gs://my-bucket --region='us-central1' -- ARG1 ARG2
          c                 .    t        j                  |        y N)r	   AddArguments)parsers    .lib/surface/dataproc/batches/submit/spark_r.pyArgszSparkR.Args(   s    %%f-    c                     t        j                  t        j                  j                        }t        j                  |      j                  |      }t        j                  |||      S r   )
dpDataprocr   ReleaseTrackGAr	   SparkRBatchFactoryUploadLocalFilesAndGetMessager   Submit)selfargsr   sparkr_batchs       r   Runz
SparkR.Run,   sT    {{4,,//0H':://5  !!,$??r   N)__name__
__module____qualname____doc__detailed_helpstaticmethodr   r    r   r   r   r      s.    #- . .@r   r   N)r#   
__future__r   r   r   googlecloudsdk.api_lib.dataprocr   r   googlecloudsdk.callioper   +googlecloudsdk.command_lib.dataproc.batchesr   r	   ReleaseTracksr   BETAr   Commandr   r&   r   r   <module>r.      si     ! &  ' : ( G L D%%**D,=,=,@,@A@T\\ @ B@r   