|dZddlmZddlmZddlmZddlmZddlmZGddejejZ y ) zSubmit a Pig job to a cluster.)absolute_import)division)unicode_literals)pig) submitterc&eZdZdZedZdZy)Piga.Submit a Pig job to a cluster. Submit a Pig job to a cluster. ## EXAMPLES To submit a Pig job with a local script, run: $ {command} --cluster=my-cluster --file=my_queries.pig To submit a Pig job with inline queries, run: $ {command} --cluster=my-cluster -e="LNS = LOAD 'gs://my_bucket/my_file.txt' AS (line)" -e="WORDS = FOREACH LNS GENERATE FLATTEN(TOKENIZE(line)) AS word" -e="GROUPS = GROUP WORDS BY word" -e="WORD_COUNTS = FOREACH GROUPS GENERATE group, COUNT(WORDS)" -e="DUMP WORD_COUNTS" ctjj|tjj|yN)rPigBaseArgsr JobSubmitter)parsers 'lib/surface/dataproc/jobs/submit/pig.pyr zPig.Args/s(KKV 'c tjj|||j|j ||j |t jj|||yr )rr ConfigureJob files_by_typeBuildLoggingConfigdriver_log_levelsrr)selfmessagesjobargss rrzPig.ConfigureJob4sXKKXsD,>,>!44!)4+A+ACDHJ''#tr#s1 %&'8>=#++y--=r