internalAddGeneratedFile( ' �J #google/cloud/dataproc/v1/jobs.protogoogle.cloud.dataproc.v1google/api/client.protogoogle/api/field_behavior.proto#google/longrunning/operations.protogoogle/protobuf/empty.proto google/protobuf/field_mask.protogoogle/protobuf/timestamp.proto"� LoggingConfigW driver_log_levels (2<.google.cloud.dataproc.v1.LoggingConfig.DriverLogLevelsEntrye DriverLogLevelsEntry key

( < value
(2-.google.cloud.dataproc.v1.LoggingConfig.Level:8
"p Level LEVEL_UNSPECIFIED ALL
 TRACE DEBUG INFO WARN ERROR FATAL OFF"� HadoopJob main_jar_file_uri

( H main_class
( H args ( B�A
 jar_file_uris ( B�A
 file_uris ( B�A
 archive_uris ( B�A
L properties (23.google.cloud.dataproc.v1.HadoopJob.PropertiesEntryB�A
D logging_config
(2\'.google.cloud.dataproc.v1.LoggingConfigB�A
1 PropertiesEntry key

(  value
( :8
B driver"� SparkJob main_jar_file_uri

( H main_class
( H args ( B�A
 jar_file_uris ( B�A
 file_uris ( B�A
 archive_uris ( B�A
K properties (22.google.cloud.dataproc.v1.SparkJob.PropertiesEntryB�A
D logging_config
(2\'.google.cloud.dataproc.v1.LoggingConfigB�A
1 PropertiesEntry key

(  value
( :8
B driver"� PySparkJob! main_python_file_uri

( B�A args ( B�A
 python_file_uris ( B�A
 jar_file_uris ( B�A
 file_uris ( B�A
 archive_uris ( B�A
M properties (24.google.cloud.dataproc.v1.PySparkJob.PropertiesEntryB�A
D logging_config
(2\'.google.cloud.dataproc.v1.LoggingConfigB�A
1 PropertiesEntry key

(  value
( :8
"! QueryList queries
( B�A"� HiveJob query_file_uri

( H9 query_list
(2#.google.cloud.dataproc.v1.QueryListH continue_on_failure
(B�A
U script_variables (26.google.cloud.dataproc.v1.HiveJob.ScriptVariablesEntryB�A
J properties (21.google.cloud.dataproc.v1.HiveJob.PropertiesEntryB�A
 jar_file_uris ( B�A
6 ScriptVariablesEntry key

(  value
( :8
1 PropertiesEntry key

(  value
( :8
B queries"� SparkSqlJob query_file_uri

( H9 query_list
(2#.google.cloud.dataproc.v1.QueryListHY script_variables (2:.google.cloud.dataproc.v1.SparkSqlJob.ScriptVariablesEntryB�A
N properties (25.google.cloud.dataproc.v1.SparkSqlJob.PropertiesEntryB�A
 jar_file_uris8 ( B�A
D logging_config
(2\'.google.cloud.dataproc.v1.LoggingConfigB�A
6 ScriptVariablesEntry key

(  value
( :8
1 PropertiesEntry key

(  value
( :8
B queries"� PigJob query_file_uri

( H9 query_list
(2#.google.cloud.dataproc.v1.QueryListH continue_on_failure
(B�A
T script_variables (25.google.cloud.dataproc.v1.PigJob.ScriptVariablesEntryB�A
I properties (20.google.cloud.dataproc.v1.PigJob.PropertiesEntryB�A
 jar_file_uris ( B�A
D logging_config
(2\'.google.cloud.dataproc.v1.LoggingConfigB�A
6 ScriptVariablesEntry key

(  value
( :8
1 PropertiesEntry key

(  value
( :8
B queries"� SparkRJob main_r_file_uri

( B�A args ( B�A
 file_uris ( B�A
 archive_uris ( B�A
L properties (23.google.cloud.dataproc.v1.SparkRJob.PropertiesEntryB�A
D logging_config
(2\'.google.cloud.dataproc.v1.LoggingConfigB�A
1 PropertiesEntry key

(  value
( :8
"� PrestoJob query_file_uri

( H9 query_list
(2#.google.cloud.dataproc.v1.QueryListH continue_on_failure
(B�A
 output_format
( B�A
 client_tags ( B�A
L properties (23.google.cloud.dataproc.v1.PrestoJob.PropertiesEntryB�A
D logging_config
(2\'.google.cloud.dataproc.v1.LoggingConfigB�A
1 PropertiesEntry key

(  value
( :8
B queries"� TrinoJob query_file_uri

( H9 query_list
(2#.google.cloud.dataproc.v1.QueryListH continue_on_failure
(B�A
 output_format
( B�A
 client_tags ( B�A
K properties (22.google.cloud.dataproc.v1.TrinoJob.PropertiesEntryB�A
D logging_config
(2\'.google.cloud.dataproc.v1.LoggingConfigB�A
1 PropertiesEntry key

(  value
( :8
B queries"�
JobPlacement cluster_name

( B�A cluster_uuid
( B�AV cluster_labels (29.google.cloud.dataproc.v1.JobPlacement.ClusterLabelsEntryB�A
4 ClusterLabelsEntry key

(  value
( :8
"� JobStatus= state

(2).google.cloud.dataproc.v1.JobStatus.StateB�A details
( B�A�A
9 state_start_time
(2.google.protobuf.TimestampB�AC substate
(2,.google.cloud.dataproc.v1.JobStatus.SubstateB�A"�
State STATE_UNSPECIFIED PENDING
 SETUP_DONE RUNNING CANCEL_PENDING CANCEL_STARTED CANCELLED DONE ERROR ATTEMPT_FAILURE "H Substate UNSPECIFIED SUBMITTED
 QUEUED STALE_STATUS"< JobReference project_id

( B�A
 job_id
( B�A
"� YarnApplication name

( B�AC state
(2/.google.cloud.dataproc.v1.YarnApplication.StateB�A progress
(B�A tracking_url
( B�A
"�
State STATE_UNSPECIFIED NEW
 NEW_SAVING SUBMITTED ACCEPTED RUNNING FINISHED FAILED KILLED"� Job> reference

(2&.google.cloud.dataproc.v1.JobReferenceB�A
> placement
(2&.google.cloud.dataproc.v1.JobPlacementB�A> hadoop_job
(2#.google.cloud.dataproc.v1.HadoopJobB�A
H< spark_job
(2".google.cloud.dataproc.v1.SparkJobB�A
H@ pyspark_job
(2$.google.cloud.dataproc.v1.PySparkJobB�A
H: hive_job
(2!.google.cloud.dataproc.v1.HiveJobB�A
H8 pig_job
(2 .google.cloud.dataproc.v1.PigJobB�A
H? spark_r_job
(2#.google.cloud.dataproc.v1.SparkRJobB�A
HC spark_sql_job
(2%.google.cloud.dataproc.v1.SparkSqlJobB�A
H> presto_job
(2#.google.cloud.dataproc.v1.PrestoJobB�A
H< trino_job
(2".google.cloud.dataproc.v1.TrinoJobB�A
H8 status
(2#.google.cloud.dataproc.v1.JobStatusB�A@ status_history (2#.google.cloud.dataproc.v1.JobStatusB�AI yarn_applications (2).google.cloud.dataproc.v1.YarnApplicationB�A\' driver_output_resource_uri
( B�A% driver_control_files_uri
( B�A> labels (2).google.cloud.dataproc.v1.Job.LabelsEntryB�A
@ scheduling
(2\'.google.cloud.dataproc.v1.JobSchedulingB�A
 job_uuid
( B�A done
(B�AW driver_scheduling_config
(20.google.cloud.dataproc.v1.DriverSchedulingConfigB�A
- LabelsEntry key

(  value
( :8
B type_job"E DriverSchedulingConfig memory_mb

(B�A vcores
(B�A"T JobScheduling" max_failures_per_hour

(B�A
 max_failures_total
(B�A
"�
SubmitJobRequest project_id

( B�A region
( B�A/ job
(2.google.cloud.dataproc.v1.JobB�A request_id
( B�A
"�
JobMetadata job_id

( B�A8 status
(2#.google.cloud.dataproc.v1.JobStatusB�A operation_type
( B�A3 start_time
(2.google.protobuf.TimestampB�A"R GetJobRequest project_id

( B�A region
( B�A job_id
( B�A"� ListJobsRequest project_id

( B�A region
( B�A page_size
(B�A
 page_token
( B�A
 cluster_name
( B�A
Y job_state_matcher
(29.google.cloud.dataproc.v1.ListJobsRequest.JobStateMatcherB�A
 filter
( B�A
"6 JobStateMatcher ALL ACTIVE
 NON_ACTIVE"�
UpdateJobRequest project_id

( B�A region
( B�A job_id
( B�A/ job
(2.google.cloud.dataproc.v1.JobB�A4 update_mask
(2.google.protobuf.FieldMaskB�A"b ListJobsResponse0 jobs
(2.google.cloud.dataproc.v1.JobB�A next_page_token
( B�A
"U CancelJobRequest project_id

( B�A region
( B�A job_id
( B�A"U DeleteJobRequest project_id

( B�A region
( B�A job_id
( B�A2� JobController�
SubmitJob*.google.cloud.dataproc.v1.SubmitJobRequest.google.cloud.dataproc.v1.Job"Y���;"6/v1/projects/{project_id}/regions/{region}/jobs:submit:
*�Aproject_id,region,job�
SubmitJobAsOperation*.google.cloud.dataproc.v1.SubmitJobRequest.google.longrunning.Operation"{���F"A/v1/projects/{project_id}/regions/{region}/jobs:submitAsOperation:
*�Aproject_id, region, job�A JobJobMetadata�
GetJob\'.google.cloud.dataproc.v1.GetJobRequest.google.cloud.dataproc.v1.Job"[���:8/v1/projects/{project_id}/regions/{region}/jobs/{job_id}�Aproject_id,region,job_id�
ListJobs).google.cloud.dataproc.v1.ListJobsRequest*.google.cloud.dataproc.v1.ListJobsResponse"f���1//v1/projects/{project_id}/regions/{region}/jobs�Aproject_id,region�Aproject_id,region,filter�
UpdateJob*.google.cloud.dataproc.v1.UpdateJobRequest.google.cloud.dataproc.v1.Job"E���?28/v1/projects/{project_id}/regions/{region}/jobs/{job_id}:job�
CancelJob*.google.cloud.dataproc.v1.CancelJobRequest.google.cloud.dataproc.v1.Job"e���D"?/v1/projects/{project_id}/regions/{region}/jobs/{job_id}:cancel:
*�Aproject_id,region,job_id�
DeleteJob*.google.cloud.dataproc.v1.DeleteJobRequest.google.protobuf.Empty"[���:*8/v1/projects/{project_id}/regions/{region}/jobs/{job_id}�Aproject_id,region,job_idK�Adataproc.googleapis.com�A.https://www.googleapis.com/auth/cloud-platformBe com.google.cloud.dataproc.v1B JobsProtoP
Z8cloud.google.com/go/dataproc/apiv1/dataprocpb;dataprocpbbproto3' , true); static::$is_initialized = true; } }