
                             S 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)	zSubmit a SparkSql batch job.    )dataproc)base)batch_submitter)sparksql_batch_factoryc                   6    \ rS rSrSrSS0r\S 5       rS rSr	g)	SparkSql   zSubmit a Spark SQL batch job.EXAMPLESz          To submit a Spark SQL job running "my-sql-script.sql" and upload it to "gs://my-bucket", run:

            $ {command} my-sql-script.sql --deps-bucket=gs://my-bucket --region=us-central1 --vars="NAME=VALUE,NAME2=VALUE2"
          c                 0    [         R                  " U 5        g N)r   AddArguments)parsers    0lib/surface/dataproc/batches/submit/spark_sql.pyArgsSparkSql.Args%   s    ''/    c                     [         R                  " [        R                  R                  5      n[
        R                  " U5      R                  U5      n[        R                  " X2U5      $ r   )
dpDataprocr   ReleaseTrackGAr   SparkSqlBatchFactoryUploadLocalFilesAndGetMessager   Submit)selfargsr   sparksql_batchs       r   RunSparkSql.Run)   sR    {{4,,//0H+@@//5  !!.DAAr    N)
__name__
__module____qualname____firstlineno____doc__detailed_helpstaticmethodr   r   __static_attributes__r    r   r   r   r      s.    %- 0 0Br   r   N)r%   googlecloudsdk.api_lib.dataprocr   r   googlecloudsdk.callioper   +googlecloudsdk.command_lib.dataproc.batchesr   r   ReleaseTracksr   BETAr   Commandr   r    r   r   <module>r/      s`     # ; ( G N D%%**D,=,=,@,@ABt|| B BBr   