
    x                         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	\R                  \	R                  5      rg
)z!Submit a Hadoop job to a cluster.    )absolute_import)division)unicode_literals)util)hadoop)	submitterc                   .    \ rS rSrSr\S 5       rS rSrg)Hadoop   a~  Submit a Hadoop job to a cluster.

Submit a Hadoop job to a cluster.

## EXAMPLES

To submit a Hadoop job that runs the main class of a jar, run:

  $ {command} --cluster=my-cluster --jar=my_jar.jar -- arg1 arg2

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

  $ {command} --cluster=my-cluster --class=org.my.main.Class \
      --jars=my_jar1.jar,my_jar2.jar -- arg1 arg2

To submit a Hadoop job that runs a jar that is already on the cluster, run:

  $ {command} --cluster=my-cluster \
      --jar=file:///usr/lib/hadoop-op/hadoop-op-examples.jar \
      -- wordcount gs://my_bucket/my_file.txt gs://my_bucket/output
c                     [         R                  R                  U5        [        R                  R                  U5        UR                  SSS9n[        R                  " U5        g )NT)requiredmutex)r   
HadoopBaseArgsr   JobSubmitteradd_argument_groupr   AddJvmDriverFlags)clsparserdriver_groups      *lib/surface/dataproc/jobs/submit/hadoop.pyr   Hadoop.Args2   sM    
6"',,d$,GL<(    c           	          [         R                  R                  XU R                  U R	                  XR
                  5      U5        [        R                  R                  XU5        g )N)r   r   ConfigureJobfiles_by_typeBuildLoggingConfigdriver_log_levelsr   r   )selfmessagesjobargss       r   r   Hadoop.ConfigureJob9   sP    
""t))*@*@A4I ''t<r    N)	__name__
__module____qualname____firstlineno____doc__classmethodr   r   __static_attributes__r$   r   r   r
   r
      s     , ) )=r   r
   N)r)   
__future__r   r   r   googlecloudsdk.api_lib.dataprocr   (googlecloudsdk.command_lib.dataproc.jobsr   r   r   r   r
   r$   r   r   <module>r/      s6     ( &  ' 0 ; >"=V	 6 6 "=r   