
                            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K
Jr  \	R                  " \	R                  R                  \	R                  R                   5       " S	 S
\	R"                  5      5       rg)Submit a Spark batch job.    )absolute_import)division)unicode_literals)dataproc)base)batch_submitter)spark_batch_factoryc                   8    \ rS rSrSrSSS.r\S 5       rS rSr	g	)
Spark   r   z.          Submit a Spark batch job.
          a~            To submit a Spark job, run:

            $ {command} --region=us-central1 --jar=my_jar.jar --deps-bucket=gs://my-bucket -- ARG1 ARG2

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

            $ {command} --region=us-central1 --class=org.my.main.Class --jars=my_jar1.jar,my_jar2.jar --deps-bucket=gs://my-bucket -- ARG1 ARG2

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

            $ {command} --region=us-central1 --class=org.apache.spark.examples.SparkPi --deps-bucket=gs://my-bucket --jars=file:///usr/lib/spark/examples/jars/spark-examples.jar -- 15
          )DESCRIPTIONEXAMPLESc                 0    [         R                  " U 5        g N)r
   AddArguments)parsers    ,lib/surface/dataproc/batches/submit/spark.pyArgs
Spark.Args4   s    $$V,    c                     [         R                  " [        R                  R                  5      n[
        R                  " U5      R                  U5      n[        R                  " X2U5      $ r   )
dpDataprocr   ReleaseTrackGAr
   SparkBatchFactoryUploadLocalFilesAndGetMessager	   Submit)selfargsr   spark_batchs       r   Run	Spark.Run8   sR    {{4,,//0H%77//5  !!+>>r    N)
__name__
__module____qualname____firstlineno____doc__detailed_helpstaticmethodr   r#   __static_attributes__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>r5      sd       &  ' : ( G K D%%**D,=,=,@,@A ?DLL  ? B ?r   