
    q                         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 Hive job to a cluster.    )absolute_import)division)unicode_literals)hive)	submitterc                   &    e Zd ZdZed        Zd Zy)Hivea  Submit a Hive job to a cluster.

  Submit a Hive job to a cluster.

  ## EXAMPLES

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

    $ {command} --cluster=my-cluster --file=my_queries.q

  To submit a Hive job with inline queries, run:

    $ {command} --cluster=my-cluster
        -e="CREATE EXTERNAL TABLE foo(bar int) LOCATION 'gs://my_bucket/'"
        -e="SELECT * FROM foo WHERE bar > 2"
  c                     t         j                  j                  |       t        j                  j                  |       y N)r   HiveBaseArgsr   JobSubmitter)clsparsers     (lib/surface/dataproc/jobs/submit/hive.pyr   z	Hive.Args,   s(    MMv'    c                     t         j                  j                  ||| j                  |       t        j
                  j                  |||       y r   )r   r   ConfigureJobfiles_by_typer   r   )selfmessagesjobargss       r   r   zHive.ConfigureJob1   s8    MMxd.@.@$G''#t<r   N)__name__
__module____qualname____doc__classmethodr   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"      s1     & &  ' 9 >=4==)00 =r   