diff --git a/Dataproc/metadata/V1/Jobs.php b/Dataproc/metadata/V1/Jobs.php index 55b6bc51acd2..d73b564b22a2 100644 --- a/Dataproc/metadata/V1/Jobs.php +++ b/Dataproc/metadata/V1/Jobs.php @@ -22,7 +22,7 @@ public static function initOnce() { \GPBMetadata\Google\Protobuf\FieldMask::initOnce(); \GPBMetadata\Google\Protobuf\Timestamp::initOnce(); $pool->internalAddGeneratedFile( - "\x0A\xBCM\x0A#google/cloud/dataproc/v1/jobs.proto\x12\x18google.cloud.dataproc.v1\x1A\x17google/api/client.proto\x1A\x1Fgoogle/api/field_behavior.proto\x1A#google/longrunning/operations.proto\x1A\x1Bgoogle/protobuf/empty.proto\x1A google/protobuf/field_mask.proto\x1A\x1Fgoogle/protobuf/timestamp.proto\"\xC1\x02\x0A\x0DLoggingConfig\x12W\x0A\x11driver_log_levels\x18\x02 \x03(\x0B2<.google.cloud.dataproc.v1.LoggingConfig.DriverLogLevelsEntry\x1Ae\x0A\x14DriverLogLevelsEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12<\x0A\x05value\x18\x02 \x01(\x0E2-.google.cloud.dataproc.v1.LoggingConfig.Level:\x028\x01\"p\x0A\x05Level\x12\x15\x0A\x11LEVEL_UNSPECIFIED\x10\x00\x12\x07\x0A\x03ALL\x10\x01\x12\x09\x0A\x05TRACE\x10\x02\x12\x09\x0A\x05DEBUG\x10\x03\x12\x08\x0A\x04INFO\x10\x04\x12\x08\x0A\x04WARN\x10\x05\x12\x09\x0A\x05ERROR\x10\x06\x12\x09\x0A\x05FATAL\x10\x07\x12\x07\x0A\x03OFF\x10\x08\"\xF1\x02\x0A\x09HadoopJob\x12\x1B\x0A\x11main_jar_file_uri\x18\x01 \x01(\x09H\x00\x12\x14\x0A\x0Amain_class\x18\x02 \x01(\x09H\x00\x12\x11\x0A\x04args\x18\x03 \x03(\x09B\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x18\x04 \x03(\x09B\x03\xE0A\x01\x12\x16\x0A\x09file_uris\x18\x05 \x03(\x09B\x03\xE0A\x01\x12\x19\x0A\x0Carchive_uris\x18\x06 \x03(\x09B\x03\xE0A\x01\x12L\x0A\x0Aproperties\x18\x07 \x03(\x0B23.google.cloud.dataproc.v1.HadoopJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x08 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x08\x0A\x06driver\"\xEF\x02\x0A\x08SparkJob\x12\x1B\x0A\x11main_jar_file_uri\x18\x01 \x01(\x09H\x00\x12\x14\x0A\x0Amain_class\x18\x02 \x01(\x09H\x00\x12\x11\x0A\x04args\x18\x03 \x03(\x09B\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x18\x04 \x03(\x09B\x03\xE0A\x01\x12\x16\x0A\x09file_uris\x18\x05 \x03(\x09B\x03\xE0A\x01\x12\x19\x0A\x0Carchive_uris\x18\x06 \x03(\x09B\x03\xE0A\x01\x12K\x0A\x0Aproperties\x18\x07 \x03(\x0B22.google.cloud.dataproc.v1.SparkJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x08 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x08\x0A\x06driver\"\xF8\x02\x0A\x0APySparkJob\x12!\x0A\x14main_python_file_uri\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x11\x0A\x04args\x18\x02 \x03(\x09B\x03\xE0A\x01\x12\x1D\x0A\x10python_file_uris\x18\x03 \x03(\x09B\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x18\x04 \x03(\x09B\x03\xE0A\x01\x12\x16\x0A\x09file_uris\x18\x05 \x03(\x09B\x03\xE0A\x01\x12\x19\x0A\x0Carchive_uris\x18\x06 \x03(\x09B\x03\xE0A\x01\x12M\x0A\x0Aproperties\x18\x07 \x03(\x0B24.google.cloud.dataproc.v1.PySparkJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x08 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01\"!\x0A\x09QueryList\x12\x14\x0A\x07queries\x18\x01 \x03(\x09B\x03\xE0A\x02\"\xB5\x03\x0A\x07HiveJob\x12\x18\x0A\x0Equery_file_uri\x18\x01 \x01(\x09H\x00\x129\x0A\x0Aquery_list\x18\x02 \x01(\x0B2#.google.cloud.dataproc.v1.QueryListH\x00\x12 \x0A\x13continue_on_failure\x18\x03 \x01(\x08B\x03\xE0A\x01\x12U\x0A\x10script_variables\x18\x04 \x03(\x0B26.google.cloud.dataproc.v1.HiveJob.ScriptVariablesEntryB\x03\xE0A\x01\x12J\x0A\x0Aproperties\x18\x05 \x03(\x0B21.google.cloud.dataproc.v1.HiveJob.PropertiesEntryB\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x18\x06 \x03(\x09B\x03\xE0A\x01\x1A6\x0A\x14ScriptVariablesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x09\x0A\x07queries\"\xE5\x03\x0A\x0BSparkSqlJob\x12\x18\x0A\x0Equery_file_uri\x18\x01 \x01(\x09H\x00\x129\x0A\x0Aquery_list\x18\x02 \x01(\x0B2#.google.cloud.dataproc.v1.QueryListH\x00\x12Y\x0A\x10script_variables\x18\x03 \x03(\x0B2:.google.cloud.dataproc.v1.SparkSqlJob.ScriptVariablesEntryB\x03\xE0A\x01\x12N\x0A\x0Aproperties\x18\x04 \x03(\x0B25.google.cloud.dataproc.v1.SparkSqlJob.PropertiesEntryB\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x188 \x03(\x09B\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x06 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A6\x0A\x14ScriptVariablesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x09\x0A\x07queries\"\xF8\x03\x0A\x06PigJob\x12\x18\x0A\x0Equery_file_uri\x18\x01 \x01(\x09H\x00\x129\x0A\x0Aquery_list\x18\x02 \x01(\x0B2#.google.cloud.dataproc.v1.QueryListH\x00\x12 \x0A\x13continue_on_failure\x18\x03 \x01(\x08B\x03\xE0A\x01\x12T\x0A\x10script_variables\x18\x04 \x03(\x0B25.google.cloud.dataproc.v1.PigJob.ScriptVariablesEntryB\x03\xE0A\x01\x12I\x0A\x0Aproperties\x18\x05 \x03(\x0B20.google.cloud.dataproc.v1.PigJob.PropertiesEntryB\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x18\x06 \x03(\x09B\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x07 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A6\x0A\x14ScriptVariablesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x09\x0A\x07queries\"\xB6\x02\x0A\x09SparkRJob\x12\x1C\x0A\x0Fmain_r_file_uri\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x11\x0A\x04args\x18\x02 \x03(\x09B\x03\xE0A\x01\x12\x16\x0A\x09file_uris\x18\x03 \x03(\x09B\x03\xE0A\x01\x12\x19\x0A\x0Carchive_uris\x18\x04 \x03(\x09B\x03\xE0A\x01\x12L\x0A\x0Aproperties\x18\x05 \x03(\x0B23.google.cloud.dataproc.v1.SparkRJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x06 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01\"\x8A\x03\x0A\x09PrestoJob\x12\x18\x0A\x0Equery_file_uri\x18\x01 \x01(\x09H\x00\x129\x0A\x0Aquery_list\x18\x02 \x01(\x0B2#.google.cloud.dataproc.v1.QueryListH\x00\x12 \x0A\x13continue_on_failure\x18\x03 \x01(\x08B\x03\xE0A\x01\x12\x1A\x0A\x0Doutput_format\x18\x04 \x01(\x09B\x03\xE0A\x01\x12\x18\x0A\x0Bclient_tags\x18\x05 \x03(\x09B\x03\xE0A\x01\x12L\x0A\x0Aproperties\x18\x06 \x03(\x0B23.google.cloud.dataproc.v1.PrestoJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x07 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x09\x0A\x07queries\"\x88\x03\x0A\x08TrinoJob\x12\x18\x0A\x0Equery_file_uri\x18\x01 \x01(\x09H\x00\x129\x0A\x0Aquery_list\x18\x02 \x01(\x0B2#.google.cloud.dataproc.v1.QueryListH\x00\x12 \x0A\x13continue_on_failure\x18\x03 \x01(\x08B\x03\xE0A\x01\x12\x1A\x0A\x0Doutput_format\x18\x04 \x01(\x09B\x03\xE0A\x01\x12\x18\x0A\x0Bclient_tags\x18\x05 \x03(\x09B\x03\xE0A\x01\x12K\x0A\x0Aproperties\x18\x06 \x03(\x0B22.google.cloud.dataproc.v1.TrinoJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x07 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x09\x0A\x07queries\"\xD8\x02\x0A\x08FlinkJob\x12\x1B\x0A\x11main_jar_file_uri\x18\x01 \x01(\x09H\x00\x12\x14\x0A\x0Amain_class\x18\x02 \x01(\x09H\x00\x12\x11\x0A\x04args\x18\x03 \x03(\x09B\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x18\x04 \x03(\x09B\x03\xE0A\x01\x12\x1A\x0A\x0Dsavepoint_uri\x18\x09 \x01(\x09B\x03\xE0A\x01\x12K\x0A\x0Aproperties\x18\x07 \x03(\x0B22.google.cloud.dataproc.v1.FlinkJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x08 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x08\x0A\x06driver\"\xD2\x01\x0A\x0CJobPlacement\x12\x19\x0A\x0Ccluster_name\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x19\x0A\x0Ccluster_uuid\x18\x02 \x01(\x09B\x03\xE0A\x03\x12V\x0A\x0Ecluster_labels\x18\x03 \x03(\x0B29.google.cloud.dataproc.v1.JobPlacement.ClusterLabelsEntryB\x03\xE0A\x01\x1A4\x0A\x12ClusterLabelsEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01\"\xD9\x03\x0A\x09JobStatus\x12=\x0A\x05state\x18\x01 \x01(\x0E2).google.cloud.dataproc.v1.JobStatus.StateB\x03\xE0A\x03\x12\x17\x0A\x07details\x18\x02 \x01(\x09B\x06\xE0A\x03\xE0A\x01\x129\x0A\x10state_start_time\x18\x06 \x01(\x0B2\x1A.google.protobuf.TimestampB\x03\xE0A\x03\x12C\x0A\x08substate\x18\x07 \x01(\x0E2,.google.cloud.dataproc.v1.JobStatus.SubstateB\x03\xE0A\x03\"\xA9\x01\x0A\x05State\x12\x15\x0A\x11STATE_UNSPECIFIED\x10\x00\x12\x0B\x0A\x07PENDING\x10\x01\x12\x0E\x0A\x0ASETUP_DONE\x10\x08\x12\x0B\x0A\x07RUNNING\x10\x02\x12\x12\x0A\x0ECANCEL_PENDING\x10\x03\x12\x12\x0A\x0ECANCEL_STARTED\x10\x07\x12\x0D\x0A\x09CANCELLED\x10\x04\x12\x08\x0A\x04DONE\x10\x05\x12\x09\x0A\x05ERROR\x10\x06\x12\x13\x0A\x0FATTEMPT_FAILURE\x10\x09\"H\x0A\x08Substate\x12\x0F\x0A\x0BUNSPECIFIED\x10\x00\x12\x0D\x0A\x09SUBMITTED\x10\x01\x12\x0A\x0A\x06QUEUED\x10\x02\x12\x10\x0A\x0CSTALE_STATUS\x10\x03\"<\x0A\x0CJobReference\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x01\x12\x13\x0A\x06job_id\x18\x02 \x01(\x09B\x03\xE0A\x01\"\xA5\x02\x0A\x0FYarnApplication\x12\x11\x0A\x04name\x18\x01 \x01(\x09B\x03\xE0A\x02\x12C\x0A\x05state\x18\x02 \x01(\x0E2/.google.cloud.dataproc.v1.YarnApplication.StateB\x03\xE0A\x02\x12\x15\x0A\x08progress\x18\x03 \x01(\x02B\x03\xE0A\x02\x12\x19\x0A\x0Ctracking_url\x18\x04 \x01(\x09B\x03\xE0A\x01\"\x87\x01\x0A\x05State\x12\x15\x0A\x11STATE_UNSPECIFIED\x10\x00\x12\x07\x0A\x03NEW\x10\x01\x12\x0E\x0A\x0ANEW_SAVING\x10\x02\x12\x0D\x0A\x09SUBMITTED\x10\x03\x12\x0C\x0A\x08ACCEPTED\x10\x04\x12\x0B\x0A\x07RUNNING\x10\x05\x12\x0C\x0A\x08FINISHED\x10\x06\x12\x0A\x0A\x06FAILED\x10\x07\x12\x0A\x0A\x06KILLED\x10\x08\"\xD4\x0A\x0A\x03Job\x12>\x0A\x09reference\x18\x01 \x01(\x0B2&.google.cloud.dataproc.v1.JobReferenceB\x03\xE0A\x01\x12>\x0A\x09placement\x18\x02 \x01(\x0B2&.google.cloud.dataproc.v1.JobPlacementB\x03\xE0A\x02\x12>\x0A\x0Ahadoop_job\x18\x03 \x01(\x0B2#.google.cloud.dataproc.v1.HadoopJobB\x03\xE0A\x01H\x00\x12<\x0A\x09spark_job\x18\x04 \x01(\x0B2\".google.cloud.dataproc.v1.SparkJobB\x03\xE0A\x01H\x00\x12@\x0A\x0Bpyspark_job\x18\x05 \x01(\x0B2\$.google.cloud.dataproc.v1.PySparkJobB\x03\xE0A\x01H\x00\x12:\x0A\x08hive_job\x18\x06 \x01(\x0B2!.google.cloud.dataproc.v1.HiveJobB\x03\xE0A\x01H\x00\x128\x0A\x07pig_job\x18\x07 \x01(\x0B2 .google.cloud.dataproc.v1.PigJobB\x03\xE0A\x01H\x00\x12?\x0A\x0Bspark_r_job\x18\x15 \x01(\x0B2#.google.cloud.dataproc.v1.SparkRJobB\x03\xE0A\x01H\x00\x12C\x0A\x0Dspark_sql_job\x18\x0C \x01(\x0B2%.google.cloud.dataproc.v1.SparkSqlJobB\x03\xE0A\x01H\x00\x12>\x0A\x0Apresto_job\x18\x17 \x01(\x0B2#.google.cloud.dataproc.v1.PrestoJobB\x03\xE0A\x01H\x00\x12<\x0A\x09trino_job\x18\x1C \x01(\x0B2\".google.cloud.dataproc.v1.TrinoJobB\x03\xE0A\x01H\x00\x12<\x0A\x09flink_job\x18\x1D \x01(\x0B2\".google.cloud.dataproc.v1.FlinkJobB\x03\xE0A\x01H\x00\x128\x0A\x06status\x18\x08 \x01(\x0B2#.google.cloud.dataproc.v1.JobStatusB\x03\xE0A\x03\x12@\x0A\x0Estatus_history\x18\x0D \x03(\x0B2#.google.cloud.dataproc.v1.JobStatusB\x03\xE0A\x03\x12I\x0A\x11yarn_applications\x18\x09 \x03(\x0B2).google.cloud.dataproc.v1.YarnApplicationB\x03\xE0A\x03\x12'\x0A\x1Adriver_output_resource_uri\x18\x11 \x01(\x09B\x03\xE0A\x03\x12%\x0A\x18driver_control_files_uri\x18\x0F \x01(\x09B\x03\xE0A\x03\x12>\x0A\x06labels\x18\x12 \x03(\x0B2).google.cloud.dataproc.v1.Job.LabelsEntryB\x03\xE0A\x01\x12@\x0A\x0Ascheduling\x18\x14 \x01(\x0B2'.google.cloud.dataproc.v1.JobSchedulingB\x03\xE0A\x01\x12\x15\x0A\x08job_uuid\x18\x16 \x01(\x09B\x03\xE0A\x03\x12\x11\x0A\x04done\x18\x18 \x01(\x08B\x03\xE0A\x03\x12W\x0A\x18driver_scheduling_config\x18\x1B \x01(\x0B20.google.cloud.dataproc.v1.DriverSchedulingConfigB\x03\xE0A\x01\x1A-\x0A\x0BLabelsEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x0A\x0A\x08type_job\"E\x0A\x16DriverSchedulingConfig\x12\x16\x0A\x09memory_mb\x18\x01 \x01(\x05B\x03\xE0A\x02\x12\x13\x0A\x06vcores\x18\x02 \x01(\x05B\x03\xE0A\x02\"T\x0A\x0DJobScheduling\x12\"\x0A\x15max_failures_per_hour\x18\x01 \x01(\x05B\x03\xE0A\x01\x12\x1F\x0A\x12max_failures_total\x18\x02 \x01(\x05B\x03\xE0A\x01\"\x8A\x01\x0A\x10SubmitJobRequest\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06region\x18\x03 \x01(\x09B\x03\xE0A\x02\x12/\x0A\x03job\x18\x02 \x01(\x0B2\x1D.google.cloud.dataproc.v1.JobB\x03\xE0A\x02\x12\x17\x0A\x0Arequest_id\x18\x04 \x01(\x09B\x03\xE0A\x01\"\xAE\x01\x0A\x0BJobMetadata\x12\x13\x0A\x06job_id\x18\x01 \x01(\x09B\x03\xE0A\x03\x128\x0A\x06status\x18\x02 \x01(\x0B2#.google.cloud.dataproc.v1.JobStatusB\x03\xE0A\x03\x12\x1B\x0A\x0Eoperation_type\x18\x03 \x01(\x09B\x03\xE0A\x03\x123\x0A\x0Astart_time\x18\x04 \x01(\x0B2\x1A.google.protobuf.TimestampB\x03\xE0A\x03\"R\x0A\x0DGetJobRequest\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06region\x18\x03 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06job_id\x18\x02 \x01(\x09B\x03\xE0A\x02\"\xB3\x02\x0A\x0FListJobsRequest\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06region\x18\x06 \x01(\x09B\x03\xE0A\x02\x12\x16\x0A\x09page_size\x18\x02 \x01(\x05B\x03\xE0A\x01\x12\x17\x0A\x0Apage_token\x18\x03 \x01(\x09B\x03\xE0A\x01\x12\x19\x0A\x0Ccluster_name\x18\x04 \x01(\x09B\x03\xE0A\x01\x12Y\x0A\x11job_state_matcher\x18\x05 \x01(\x0E29.google.cloud.dataproc.v1.ListJobsRequest.JobStateMatcherB\x03\xE0A\x01\x12\x13\x0A\x06filter\x18\x07 \x01(\x09B\x03\xE0A\x01\"6\x0A\x0FJobStateMatcher\x12\x07\x0A\x03ALL\x10\x00\x12\x0A\x0A\x06ACTIVE\x10\x01\x12\x0E\x0A\x0ANON_ACTIVE\x10\x02\"\xBC\x01\x0A\x10UpdateJobRequest\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06region\x18\x02 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06job_id\x18\x03 \x01(\x09B\x03\xE0A\x02\x12/\x0A\x03job\x18\x04 \x01(\x0B2\x1D.google.cloud.dataproc.v1.JobB\x03\xE0A\x02\x124\x0A\x0Bupdate_mask\x18\x05 \x01(\x0B2\x1A.google.protobuf.FieldMaskB\x03\xE0A\x02\"|\x0A\x10ListJobsResponse\x120\x0A\x04jobs\x18\x01 \x03(\x0B2\x1D.google.cloud.dataproc.v1.JobB\x03\xE0A\x03\x12\x1C\x0A\x0Fnext_page_token\x18\x02 \x01(\x09B\x03\xE0A\x01\x12\x18\x0A\x0Bunreachable\x18\x03 \x03(\x09B\x03\xE0A\x03\"U\x0A\x10CancelJobRequest\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06region\x18\x03 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06job_id\x18\x02 \x01(\x09B\x03\xE0A\x02\"U\x0A\x10DeleteJobRequest\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06region\x18\x03 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06job_id\x18\x02 \x01(\x09B\x03\xE0A\x022\xFC\x0A\x0A\x0DJobController\x12\xB1\x01\x0A\x09SubmitJob\x12*.google.cloud.dataproc.v1.SubmitJobRequest\x1A\x1D.google.cloud.dataproc.v1.Job\"Y\xDAA\x15project_id,region,job\x82\xD3\xE4\x93\x02;\"6/v1/projects/{project_id}/regions/{region}/jobs:submit:\x01*\x12\xDE\x01\x0A\x14SubmitJobAsOperation\x12*.google.cloud.dataproc.v1.SubmitJobRequest\x1A\x1D.google.longrunning.Operation\"{\xCAA\x12\x0A\x03Job\x12\x0BJobMetadata\xDAA\x17project_id, region, job\x82\xD3\xE4\x93\x02F\"A/v1/projects/{project_id}/regions/{region}/jobs:submitAsOperation:\x01*\x12\xAD\x01\x0A\x06GetJob\x12'.google.cloud.dataproc.v1.GetJobRequest\x1A\x1D.google.cloud.dataproc.v1.Job\"[\xDAA\x18project_id,region,job_id\x82\xD3\xE4\x93\x02:\x128/v1/projects/{project_id}/regions/{region}/jobs/{job_id}\x12\xC9\x01\x0A\x08ListJobs\x12).google.cloud.dataproc.v1.ListJobsRequest\x1A*.google.cloud.dataproc.v1.ListJobsResponse\"f\xDAA\x11project_id,region\xDAA\x18project_id,region,filter\x82\xD3\xE4\x93\x021\x12//v1/projects/{project_id}/regions/{region}/jobs\x12\x9D\x01\x0A\x09UpdateJob\x12*.google.cloud.dataproc.v1.UpdateJobRequest\x1A\x1D.google.cloud.dataproc.v1.Job\"E\x82\xD3\xE4\x93\x02?28/v1/projects/{project_id}/regions/{region}/jobs/{job_id}:\x03job\x12\xBD\x01\x0A\x09CancelJob\x12*.google.cloud.dataproc.v1.CancelJobRequest\x1A\x1D.google.cloud.dataproc.v1.Job\"e\xDAA\x18project_id,region,job_id\x82\xD3\xE4\x93\x02D\"?/v1/projects/{project_id}/regions/{region}/jobs/{job_id}:cancel:\x01*\x12\xAC\x01\x0A\x09DeleteJob\x12*.google.cloud.dataproc.v1.DeleteJobRequest\x1A\x16.google.protobuf.Empty\"[\xDAA\x18project_id,region,job_id\x82\xD3\xE4\x93\x02:*8/v1/projects/{project_id}/regions/{region}/jobs/{job_id}\x1AK\xCAA\x17dataproc.googleapis.com\xD2A.https://www.googleapis.com/auth/cloud-platformBh\x0A\x1Ccom.google.cloud.dataproc.v1B\x09JobsProtoP\x01Z;cloud.google.com/go/dataproc/v2/apiv1/dataprocpb;dataprocpbb\x06proto3" + "\x0A\xF8M\x0A#google/cloud/dataproc/v1/jobs.proto\x12\x18google.cloud.dataproc.v1\x1A\x17google/api/client.proto\x1A\x1Fgoogle/api/field_behavior.proto\x1A#google/longrunning/operations.proto\x1A\x1Bgoogle/protobuf/empty.proto\x1A google/protobuf/field_mask.proto\x1A\x1Fgoogle/protobuf/timestamp.proto\"\xC1\x02\x0A\x0DLoggingConfig\x12W\x0A\x11driver_log_levels\x18\x02 \x03(\x0B2<.google.cloud.dataproc.v1.LoggingConfig.DriverLogLevelsEntry\x1Ae\x0A\x14DriverLogLevelsEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12<\x0A\x05value\x18\x02 \x01(\x0E2-.google.cloud.dataproc.v1.LoggingConfig.Level:\x028\x01\"p\x0A\x05Level\x12\x15\x0A\x11LEVEL_UNSPECIFIED\x10\x00\x12\x07\x0A\x03ALL\x10\x01\x12\x09\x0A\x05TRACE\x10\x02\x12\x09\x0A\x05DEBUG\x10\x03\x12\x08\x0A\x04INFO\x10\x04\x12\x08\x0A\x04WARN\x10\x05\x12\x09\x0A\x05ERROR\x10\x06\x12\x09\x0A\x05FATAL\x10\x07\x12\x07\x0A\x03OFF\x10\x08\"\xF1\x02\x0A\x09HadoopJob\x12\x1B\x0A\x11main_jar_file_uri\x18\x01 \x01(\x09H\x00\x12\x14\x0A\x0Amain_class\x18\x02 \x01(\x09H\x00\x12\x11\x0A\x04args\x18\x03 \x03(\x09B\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x18\x04 \x03(\x09B\x03\xE0A\x01\x12\x16\x0A\x09file_uris\x18\x05 \x03(\x09B\x03\xE0A\x01\x12\x19\x0A\x0Carchive_uris\x18\x06 \x03(\x09B\x03\xE0A\x01\x12L\x0A\x0Aproperties\x18\x07 \x03(\x0B23.google.cloud.dataproc.v1.HadoopJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x08 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x08\x0A\x06driver\"\xEF\x02\x0A\x08SparkJob\x12\x1B\x0A\x11main_jar_file_uri\x18\x01 \x01(\x09H\x00\x12\x14\x0A\x0Amain_class\x18\x02 \x01(\x09H\x00\x12\x11\x0A\x04args\x18\x03 \x03(\x09B\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x18\x04 \x03(\x09B\x03\xE0A\x01\x12\x16\x0A\x09file_uris\x18\x05 \x03(\x09B\x03\xE0A\x01\x12\x19\x0A\x0Carchive_uris\x18\x06 \x03(\x09B\x03\xE0A\x01\x12K\x0A\x0Aproperties\x18\x07 \x03(\x0B22.google.cloud.dataproc.v1.SparkJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x08 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x08\x0A\x06driver\"\xF8\x02\x0A\x0APySparkJob\x12!\x0A\x14main_python_file_uri\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x11\x0A\x04args\x18\x02 \x03(\x09B\x03\xE0A\x01\x12\x1D\x0A\x10python_file_uris\x18\x03 \x03(\x09B\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x18\x04 \x03(\x09B\x03\xE0A\x01\x12\x16\x0A\x09file_uris\x18\x05 \x03(\x09B\x03\xE0A\x01\x12\x19\x0A\x0Carchive_uris\x18\x06 \x03(\x09B\x03\xE0A\x01\x12M\x0A\x0Aproperties\x18\x07 \x03(\x0B24.google.cloud.dataproc.v1.PySparkJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x08 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01\"!\x0A\x09QueryList\x12\x14\x0A\x07queries\x18\x01 \x03(\x09B\x03\xE0A\x02\"\xB5\x03\x0A\x07HiveJob\x12\x18\x0A\x0Equery_file_uri\x18\x01 \x01(\x09H\x00\x129\x0A\x0Aquery_list\x18\x02 \x01(\x0B2#.google.cloud.dataproc.v1.QueryListH\x00\x12 \x0A\x13continue_on_failure\x18\x03 \x01(\x08B\x03\xE0A\x01\x12U\x0A\x10script_variables\x18\x04 \x03(\x0B26.google.cloud.dataproc.v1.HiveJob.ScriptVariablesEntryB\x03\xE0A\x01\x12J\x0A\x0Aproperties\x18\x05 \x03(\x0B21.google.cloud.dataproc.v1.HiveJob.PropertiesEntryB\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x18\x06 \x03(\x09B\x03\xE0A\x01\x1A6\x0A\x14ScriptVariablesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x09\x0A\x07queries\"\xE5\x03\x0A\x0BSparkSqlJob\x12\x18\x0A\x0Equery_file_uri\x18\x01 \x01(\x09H\x00\x129\x0A\x0Aquery_list\x18\x02 \x01(\x0B2#.google.cloud.dataproc.v1.QueryListH\x00\x12Y\x0A\x10script_variables\x18\x03 \x03(\x0B2:.google.cloud.dataproc.v1.SparkSqlJob.ScriptVariablesEntryB\x03\xE0A\x01\x12N\x0A\x0Aproperties\x18\x04 \x03(\x0B25.google.cloud.dataproc.v1.SparkSqlJob.PropertiesEntryB\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x188 \x03(\x09B\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x06 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A6\x0A\x14ScriptVariablesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x09\x0A\x07queries\"\xF8\x03\x0A\x06PigJob\x12\x18\x0A\x0Equery_file_uri\x18\x01 \x01(\x09H\x00\x129\x0A\x0Aquery_list\x18\x02 \x01(\x0B2#.google.cloud.dataproc.v1.QueryListH\x00\x12 \x0A\x13continue_on_failure\x18\x03 \x01(\x08B\x03\xE0A\x01\x12T\x0A\x10script_variables\x18\x04 \x03(\x0B25.google.cloud.dataproc.v1.PigJob.ScriptVariablesEntryB\x03\xE0A\x01\x12I\x0A\x0Aproperties\x18\x05 \x03(\x0B20.google.cloud.dataproc.v1.PigJob.PropertiesEntryB\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x18\x06 \x03(\x09B\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x07 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A6\x0A\x14ScriptVariablesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x09\x0A\x07queries\"\xB6\x02\x0A\x09SparkRJob\x12\x1C\x0A\x0Fmain_r_file_uri\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x11\x0A\x04args\x18\x02 \x03(\x09B\x03\xE0A\x01\x12\x16\x0A\x09file_uris\x18\x03 \x03(\x09B\x03\xE0A\x01\x12\x19\x0A\x0Carchive_uris\x18\x04 \x03(\x09B\x03\xE0A\x01\x12L\x0A\x0Aproperties\x18\x05 \x03(\x0B23.google.cloud.dataproc.v1.SparkRJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x06 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01\"\x8A\x03\x0A\x09PrestoJob\x12\x18\x0A\x0Equery_file_uri\x18\x01 \x01(\x09H\x00\x129\x0A\x0Aquery_list\x18\x02 \x01(\x0B2#.google.cloud.dataproc.v1.QueryListH\x00\x12 \x0A\x13continue_on_failure\x18\x03 \x01(\x08B\x03\xE0A\x01\x12\x1A\x0A\x0Doutput_format\x18\x04 \x01(\x09B\x03\xE0A\x01\x12\x18\x0A\x0Bclient_tags\x18\x05 \x03(\x09B\x03\xE0A\x01\x12L\x0A\x0Aproperties\x18\x06 \x03(\x0B23.google.cloud.dataproc.v1.PrestoJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x07 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x09\x0A\x07queries\"\x88\x03\x0A\x08TrinoJob\x12\x18\x0A\x0Equery_file_uri\x18\x01 \x01(\x09H\x00\x129\x0A\x0Aquery_list\x18\x02 \x01(\x0B2#.google.cloud.dataproc.v1.QueryListH\x00\x12 \x0A\x13continue_on_failure\x18\x03 \x01(\x08B\x03\xE0A\x01\x12\x1A\x0A\x0Doutput_format\x18\x04 \x01(\x09B\x03\xE0A\x01\x12\x18\x0A\x0Bclient_tags\x18\x05 \x03(\x09B\x03\xE0A\x01\x12K\x0A\x0Aproperties\x18\x06 \x03(\x0B22.google.cloud.dataproc.v1.TrinoJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x07 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x09\x0A\x07queries\"\xD8\x02\x0A\x08FlinkJob\x12\x1B\x0A\x11main_jar_file_uri\x18\x01 \x01(\x09H\x00\x12\x14\x0A\x0Amain_class\x18\x02 \x01(\x09H\x00\x12\x11\x0A\x04args\x18\x03 \x03(\x09B\x03\xE0A\x01\x12\x1A\x0A\x0Djar_file_uris\x18\x04 \x03(\x09B\x03\xE0A\x01\x12\x1A\x0A\x0Dsavepoint_uri\x18\x09 \x01(\x09B\x03\xE0A\x01\x12K\x0A\x0Aproperties\x18\x07 \x03(\x0B22.google.cloud.dataproc.v1.FlinkJob.PropertiesEntryB\x03\xE0A\x01\x12D\x0A\x0Elogging_config\x18\x08 \x01(\x0B2'.google.cloud.dataproc.v1.LoggingConfigB\x03\xE0A\x01\x1A1\x0A\x0FPropertiesEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x08\x0A\x06driver\"\xD2\x01\x0A\x0CJobPlacement\x12\x19\x0A\x0Ccluster_name\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x19\x0A\x0Ccluster_uuid\x18\x02 \x01(\x09B\x03\xE0A\x03\x12V\x0A\x0Ecluster_labels\x18\x03 \x03(\x0B29.google.cloud.dataproc.v1.JobPlacement.ClusterLabelsEntryB\x03\xE0A\x01\x1A4\x0A\x12ClusterLabelsEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01\"\xD9\x03\x0A\x09JobStatus\x12=\x0A\x05state\x18\x01 \x01(\x0E2).google.cloud.dataproc.v1.JobStatus.StateB\x03\xE0A\x03\x12\x17\x0A\x07details\x18\x02 \x01(\x09B\x06\xE0A\x03\xE0A\x01\x129\x0A\x10state_start_time\x18\x06 \x01(\x0B2\x1A.google.protobuf.TimestampB\x03\xE0A\x03\x12C\x0A\x08substate\x18\x07 \x01(\x0E2,.google.cloud.dataproc.v1.JobStatus.SubstateB\x03\xE0A\x03\"\xA9\x01\x0A\x05State\x12\x15\x0A\x11STATE_UNSPECIFIED\x10\x00\x12\x0B\x0A\x07PENDING\x10\x01\x12\x0E\x0A\x0ASETUP_DONE\x10\x08\x12\x0B\x0A\x07RUNNING\x10\x02\x12\x12\x0A\x0ECANCEL_PENDING\x10\x03\x12\x12\x0A\x0ECANCEL_STARTED\x10\x07\x12\x0D\x0A\x09CANCELLED\x10\x04\x12\x08\x0A\x04DONE\x10\x05\x12\x09\x0A\x05ERROR\x10\x06\x12\x13\x0A\x0FATTEMPT_FAILURE\x10\x09\"H\x0A\x08Substate\x12\x0F\x0A\x0BUNSPECIFIED\x10\x00\x12\x0D\x0A\x09SUBMITTED\x10\x01\x12\x0A\x0A\x06QUEUED\x10\x02\x12\x10\x0A\x0CSTALE_STATUS\x10\x03\"<\x0A\x0CJobReference\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x01\x12\x13\x0A\x06job_id\x18\x02 \x01(\x09B\x03\xE0A\x01\"\xE1\x02\x0A\x0FYarnApplication\x12\x11\x0A\x04name\x18\x01 \x01(\x09B\x03\xE0A\x02\x12C\x0A\x05state\x18\x02 \x01(\x0E2/.google.cloud.dataproc.v1.YarnApplication.StateB\x03\xE0A\x02\x12\x15\x0A\x08progress\x18\x03 \x01(\x02B\x03\xE0A\x02\x12\x19\x0A\x0Ctracking_url\x18\x04 \x01(\x09B\x03\xE0A\x01\x12\x1A\x0A\x0Dvcore_seconds\x18\x05 \x01(\x03B\x03\xE0A\x01\x12\x1E\x0A\x11memory_mb_seconds\x18\x06 \x01(\x03B\x03\xE0A\x01\"\x87\x01\x0A\x05State\x12\x15\x0A\x11STATE_UNSPECIFIED\x10\x00\x12\x07\x0A\x03NEW\x10\x01\x12\x0E\x0A\x0ANEW_SAVING\x10\x02\x12\x0D\x0A\x09SUBMITTED\x10\x03\x12\x0C\x0A\x08ACCEPTED\x10\x04\x12\x0B\x0A\x07RUNNING\x10\x05\x12\x0C\x0A\x08FINISHED\x10\x06\x12\x0A\x0A\x06FAILED\x10\x07\x12\x0A\x0A\x06KILLED\x10\x08\"\xD4\x0A\x0A\x03Job\x12>\x0A\x09reference\x18\x01 \x01(\x0B2&.google.cloud.dataproc.v1.JobReferenceB\x03\xE0A\x01\x12>\x0A\x09placement\x18\x02 \x01(\x0B2&.google.cloud.dataproc.v1.JobPlacementB\x03\xE0A\x02\x12>\x0A\x0Ahadoop_job\x18\x03 \x01(\x0B2#.google.cloud.dataproc.v1.HadoopJobB\x03\xE0A\x01H\x00\x12<\x0A\x09spark_job\x18\x04 \x01(\x0B2\".google.cloud.dataproc.v1.SparkJobB\x03\xE0A\x01H\x00\x12@\x0A\x0Bpyspark_job\x18\x05 \x01(\x0B2\$.google.cloud.dataproc.v1.PySparkJobB\x03\xE0A\x01H\x00\x12:\x0A\x08hive_job\x18\x06 \x01(\x0B2!.google.cloud.dataproc.v1.HiveJobB\x03\xE0A\x01H\x00\x128\x0A\x07pig_job\x18\x07 \x01(\x0B2 .google.cloud.dataproc.v1.PigJobB\x03\xE0A\x01H\x00\x12?\x0A\x0Bspark_r_job\x18\x15 \x01(\x0B2#.google.cloud.dataproc.v1.SparkRJobB\x03\xE0A\x01H\x00\x12C\x0A\x0Dspark_sql_job\x18\x0C \x01(\x0B2%.google.cloud.dataproc.v1.SparkSqlJobB\x03\xE0A\x01H\x00\x12>\x0A\x0Apresto_job\x18\x17 \x01(\x0B2#.google.cloud.dataproc.v1.PrestoJobB\x03\xE0A\x01H\x00\x12<\x0A\x09trino_job\x18\x1C \x01(\x0B2\".google.cloud.dataproc.v1.TrinoJobB\x03\xE0A\x01H\x00\x12<\x0A\x09flink_job\x18\x1D \x01(\x0B2\".google.cloud.dataproc.v1.FlinkJobB\x03\xE0A\x01H\x00\x128\x0A\x06status\x18\x08 \x01(\x0B2#.google.cloud.dataproc.v1.JobStatusB\x03\xE0A\x03\x12@\x0A\x0Estatus_history\x18\x0D \x03(\x0B2#.google.cloud.dataproc.v1.JobStatusB\x03\xE0A\x03\x12I\x0A\x11yarn_applications\x18\x09 \x03(\x0B2).google.cloud.dataproc.v1.YarnApplicationB\x03\xE0A\x03\x12'\x0A\x1Adriver_output_resource_uri\x18\x11 \x01(\x09B\x03\xE0A\x03\x12%\x0A\x18driver_control_files_uri\x18\x0F \x01(\x09B\x03\xE0A\x03\x12>\x0A\x06labels\x18\x12 \x03(\x0B2).google.cloud.dataproc.v1.Job.LabelsEntryB\x03\xE0A\x01\x12@\x0A\x0Ascheduling\x18\x14 \x01(\x0B2'.google.cloud.dataproc.v1.JobSchedulingB\x03\xE0A\x01\x12\x15\x0A\x08job_uuid\x18\x16 \x01(\x09B\x03\xE0A\x03\x12\x11\x0A\x04done\x18\x18 \x01(\x08B\x03\xE0A\x03\x12W\x0A\x18driver_scheduling_config\x18\x1B \x01(\x0B20.google.cloud.dataproc.v1.DriverSchedulingConfigB\x03\xE0A\x01\x1A-\x0A\x0BLabelsEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12\x0D\x0A\x05value\x18\x02 \x01(\x09:\x028\x01B\x0A\x0A\x08type_job\"E\x0A\x16DriverSchedulingConfig\x12\x16\x0A\x09memory_mb\x18\x01 \x01(\x05B\x03\xE0A\x02\x12\x13\x0A\x06vcores\x18\x02 \x01(\x05B\x03\xE0A\x02\"T\x0A\x0DJobScheduling\x12\"\x0A\x15max_failures_per_hour\x18\x01 \x01(\x05B\x03\xE0A\x01\x12\x1F\x0A\x12max_failures_total\x18\x02 \x01(\x05B\x03\xE0A\x01\"\x8A\x01\x0A\x10SubmitJobRequest\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06region\x18\x03 \x01(\x09B\x03\xE0A\x02\x12/\x0A\x03job\x18\x02 \x01(\x0B2\x1D.google.cloud.dataproc.v1.JobB\x03\xE0A\x02\x12\x17\x0A\x0Arequest_id\x18\x04 \x01(\x09B\x03\xE0A\x01\"\xAE\x01\x0A\x0BJobMetadata\x12\x13\x0A\x06job_id\x18\x01 \x01(\x09B\x03\xE0A\x03\x128\x0A\x06status\x18\x02 \x01(\x0B2#.google.cloud.dataproc.v1.JobStatusB\x03\xE0A\x03\x12\x1B\x0A\x0Eoperation_type\x18\x03 \x01(\x09B\x03\xE0A\x03\x123\x0A\x0Astart_time\x18\x04 \x01(\x0B2\x1A.google.protobuf.TimestampB\x03\xE0A\x03\"R\x0A\x0DGetJobRequest\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06region\x18\x03 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06job_id\x18\x02 \x01(\x09B\x03\xE0A\x02\"\xB3\x02\x0A\x0FListJobsRequest\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06region\x18\x06 \x01(\x09B\x03\xE0A\x02\x12\x16\x0A\x09page_size\x18\x02 \x01(\x05B\x03\xE0A\x01\x12\x17\x0A\x0Apage_token\x18\x03 \x01(\x09B\x03\xE0A\x01\x12\x19\x0A\x0Ccluster_name\x18\x04 \x01(\x09B\x03\xE0A\x01\x12Y\x0A\x11job_state_matcher\x18\x05 \x01(\x0E29.google.cloud.dataproc.v1.ListJobsRequest.JobStateMatcherB\x03\xE0A\x01\x12\x13\x0A\x06filter\x18\x07 \x01(\x09B\x03\xE0A\x01\"6\x0A\x0FJobStateMatcher\x12\x07\x0A\x03ALL\x10\x00\x12\x0A\x0A\x06ACTIVE\x10\x01\x12\x0E\x0A\x0ANON_ACTIVE\x10\x02\"\xBC\x01\x0A\x10UpdateJobRequest\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06region\x18\x02 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06job_id\x18\x03 \x01(\x09B\x03\xE0A\x02\x12/\x0A\x03job\x18\x04 \x01(\x0B2\x1D.google.cloud.dataproc.v1.JobB\x03\xE0A\x02\x124\x0A\x0Bupdate_mask\x18\x05 \x01(\x0B2\x1A.google.protobuf.FieldMaskB\x03\xE0A\x02\"|\x0A\x10ListJobsResponse\x120\x0A\x04jobs\x18\x01 \x03(\x0B2\x1D.google.cloud.dataproc.v1.JobB\x03\xE0A\x03\x12\x1C\x0A\x0Fnext_page_token\x18\x02 \x01(\x09B\x03\xE0A\x01\x12\x18\x0A\x0Bunreachable\x18\x03 \x03(\x09B\x03\xE0A\x03\"U\x0A\x10CancelJobRequest\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06region\x18\x03 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06job_id\x18\x02 \x01(\x09B\x03\xE0A\x02\"U\x0A\x10DeleteJobRequest\x12\x17\x0A\x0Aproject_id\x18\x01 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06region\x18\x03 \x01(\x09B\x03\xE0A\x02\x12\x13\x0A\x06job_id\x18\x02 \x01(\x09B\x03\xE0A\x022\xFC\x0A\x0A\x0DJobController\x12\xB1\x01\x0A\x09SubmitJob\x12*.google.cloud.dataproc.v1.SubmitJobRequest\x1A\x1D.google.cloud.dataproc.v1.Job\"Y\xDAA\x15project_id,region,job\x82\xD3\xE4\x93\x02;\"6/v1/projects/{project_id}/regions/{region}/jobs:submit:\x01*\x12\xDE\x01\x0A\x14SubmitJobAsOperation\x12*.google.cloud.dataproc.v1.SubmitJobRequest\x1A\x1D.google.longrunning.Operation\"{\xCAA\x12\x0A\x03Job\x12\x0BJobMetadata\xDAA\x17project_id, region, job\x82\xD3\xE4\x93\x02F\"A/v1/projects/{project_id}/regions/{region}/jobs:submitAsOperation:\x01*\x12\xAD\x01\x0A\x06GetJob\x12'.google.cloud.dataproc.v1.GetJobRequest\x1A\x1D.google.cloud.dataproc.v1.Job\"[\xDAA\x18project_id,region,job_id\x82\xD3\xE4\x93\x02:\x128/v1/projects/{project_id}/regions/{region}/jobs/{job_id}\x12\xC9\x01\x0A\x08ListJobs\x12).google.cloud.dataproc.v1.ListJobsRequest\x1A*.google.cloud.dataproc.v1.ListJobsResponse\"f\xDAA\x11project_id,region\xDAA\x18project_id,region,filter\x82\xD3\xE4\x93\x021\x12//v1/projects/{project_id}/regions/{region}/jobs\x12\x9D\x01\x0A\x09UpdateJob\x12*.google.cloud.dataproc.v1.UpdateJobRequest\x1A\x1D.google.cloud.dataproc.v1.Job\"E\x82\xD3\xE4\x93\x02?28/v1/projects/{project_id}/regions/{region}/jobs/{job_id}:\x03job\x12\xBD\x01\x0A\x09CancelJob\x12*.google.cloud.dataproc.v1.CancelJobRequest\x1A\x1D.google.cloud.dataproc.v1.Job\"e\xDAA\x18project_id,region,job_id\x82\xD3\xE4\x93\x02D\"?/v1/projects/{project_id}/regions/{region}/jobs/{job_id}:cancel:\x01*\x12\xAC\x01\x0A\x09DeleteJob\x12*.google.cloud.dataproc.v1.DeleteJobRequest\x1A\x16.google.protobuf.Empty\"[\xDAA\x18project_id,region,job_id\x82\xD3\xE4\x93\x02:*8/v1/projects/{project_id}/regions/{region}/jobs/{job_id}\x1AK\xCAA\x17dataproc.googleapis.com\xD2A.https://www.googleapis.com/auth/cloud-platformBh\x0A\x1Ccom.google.cloud.dataproc.v1B\x09JobsProtoP\x01Z;cloud.google.com/go/dataproc/v2/apiv1/dataprocpb;dataprocpbb\x06proto3" , true); static::$is_initialized = true; diff --git a/Dataproc/src/V1/ListJobsRequest.php b/Dataproc/src/V1/ListJobsRequest.php index e2a84ddd89e5..d3137e4ef0a6 100644 --- a/Dataproc/src/V1/ListJobsRequest.php +++ b/Dataproc/src/V1/ListJobsRequest.php @@ -60,13 +60,16 @@ class ListJobsRequest extends \Google\Protobuf\Internal\Message * Optional. A filter constraining the jobs to list. Filters are * case-sensitive and have the following syntax: * [field = value] AND [field [= value]] ... - * where **field** is `status.state` or `labels.[KEY]`, and `[KEY]` is a label - * key. **value** can be `*` to match all values. + * where **field** is `status.state` or `insertTime`, or `labels.[KEY]`, and + * `[KEY]` is a label key. **value** can be `*` to match all values. * `status.state` can be either `ACTIVE` or `NON_ACTIVE`. - * Only the logical `AND` operator is supported; space-separated items are - * treated as having an implicit `AND` operator. + * Allows `insertTime` to be a timestamp in RFC 3339 format in double quotes, + * such as `2025-01-01T00:00:00Z`. Only the logical `AND` operator is + * supported; space-separated items are treated as having an implicit `AND` + * operator. * Example filter: - * status.state = ACTIVE AND labels.env = staging AND labels.starred = * + * status.state = ACTIVE AND labels.env = staging AND labels.starred = * AND + * insertTime <= "2025-01-01T00:00:00Z" * * Generated from protobuf field string filter = 7 [(.google.api.field_behavior) = OPTIONAL]; */ @@ -97,15 +100,18 @@ public static function build(string $projectId, string $region): self * * [field = value] AND [field [= value]] ... * - * where **field** is `status.state` or `labels.[KEY]`, and `[KEY]` is a label - * key. **value** can be `*` to match all values. + * where **field** is `status.state` or `insertTime`, or `labels.[KEY]`, and + * `[KEY]` is a label key. **value** can be `*` to match all values. * `status.state` can be either `ACTIVE` or `NON_ACTIVE`. - * Only the logical `AND` operator is supported; space-separated items are - * treated as having an implicit `AND` operator. + * Allows `insertTime` to be a timestamp in RFC 3339 format in double quotes, + * such as `2025-01-01T00:00:00Z`. Only the logical `AND` operator is + * supported; space-separated items are treated as having an implicit `AND` + * operator. * * Example filter: * - * status.state = ACTIVE AND labels.env = staging AND labels.starred = * + * status.state = ACTIVE AND labels.env = staging AND labels.starred = * AND + * insertTime <= "2025-01-01T00:00:00Z" * * @return \Google\Cloud\Dataproc\V1\ListJobsRequest * @@ -146,13 +152,16 @@ public static function buildFromProjectIdRegionFilter(string $projectId, string * Optional. A filter constraining the jobs to list. Filters are * case-sensitive and have the following syntax: * [field = value] AND [field [= value]] ... - * where **field** is `status.state` or `labels.[KEY]`, and `[KEY]` is a label - * key. **value** can be `*` to match all values. + * where **field** is `status.state` or `insertTime`, or `labels.[KEY]`, and + * `[KEY]` is a label key. **value** can be `*` to match all values. * `status.state` can be either `ACTIVE` or `NON_ACTIVE`. - * Only the logical `AND` operator is supported; space-separated items are - * treated as having an implicit `AND` operator. + * Allows `insertTime` to be a timestamp in RFC 3339 format in double quotes, + * such as `2025-01-01T00:00:00Z`. Only the logical `AND` operator is + * supported; space-separated items are treated as having an implicit `AND` + * operator. * Example filter: - * status.state = ACTIVE AND labels.env = staging AND labels.starred = * + * status.state = ACTIVE AND labels.env = staging AND labels.starred = * AND + * insertTime <= "2025-01-01T00:00:00Z" * } */ public function __construct($data = NULL) { @@ -330,13 +339,16 @@ public function setJobStateMatcher($var) * Optional. A filter constraining the jobs to list. Filters are * case-sensitive and have the following syntax: * [field = value] AND [field [= value]] ... - * where **field** is `status.state` or `labels.[KEY]`, and `[KEY]` is a label - * key. **value** can be `*` to match all values. + * where **field** is `status.state` or `insertTime`, or `labels.[KEY]`, and + * `[KEY]` is a label key. **value** can be `*` to match all values. * `status.state` can be either `ACTIVE` or `NON_ACTIVE`. - * Only the logical `AND` operator is supported; space-separated items are - * treated as having an implicit `AND` operator. + * Allows `insertTime` to be a timestamp in RFC 3339 format in double quotes, + * such as `2025-01-01T00:00:00Z`. Only the logical `AND` operator is + * supported; space-separated items are treated as having an implicit `AND` + * operator. * Example filter: - * status.state = ACTIVE AND labels.env = staging AND labels.starred = * + * status.state = ACTIVE AND labels.env = staging AND labels.starred = * AND + * insertTime <= "2025-01-01T00:00:00Z" * * Generated from protobuf field string filter = 7 [(.google.api.field_behavior) = OPTIONAL]; * @return string @@ -350,13 +362,16 @@ public function getFilter() * Optional. A filter constraining the jobs to list. Filters are * case-sensitive and have the following syntax: * [field = value] AND [field [= value]] ... - * where **field** is `status.state` or `labels.[KEY]`, and `[KEY]` is a label - * key. **value** can be `*` to match all values. + * where **field** is `status.state` or `insertTime`, or `labels.[KEY]`, and + * `[KEY]` is a label key. **value** can be `*` to match all values. * `status.state` can be either `ACTIVE` or `NON_ACTIVE`. - * Only the logical `AND` operator is supported; space-separated items are - * treated as having an implicit `AND` operator. + * Allows `insertTime` to be a timestamp in RFC 3339 format in double quotes, + * such as `2025-01-01T00:00:00Z`. Only the logical `AND` operator is + * supported; space-separated items are treated as having an implicit `AND` + * operator. * Example filter: - * status.state = ACTIVE AND labels.env = staging AND labels.starred = * + * status.state = ACTIVE AND labels.env = staging AND labels.starred = * AND + * insertTime <= "2025-01-01T00:00:00Z" * * Generated from protobuf field string filter = 7 [(.google.api.field_behavior) = OPTIONAL]; * @param string $var diff --git a/Dataproc/src/V1/YarnApplication.php b/Dataproc/src/V1/YarnApplication.php index 219ea1571d4e..4ec7454d6828 100644 --- a/Dataproc/src/V1/YarnApplication.php +++ b/Dataproc/src/V1/YarnApplication.php @@ -45,6 +45,20 @@ class YarnApplication extends \Google\Protobuf\Internal\Message * Generated from protobuf field string tracking_url = 4 [(.google.api.field_behavior) = OPTIONAL]; */ protected $tracking_url = ''; + /** + * Optional. The cumulative CPU time consumed by the application for a job, + * measured in vcore-seconds. + * + * Generated from protobuf field int64 vcore_seconds = 5 [(.google.api.field_behavior) = OPTIONAL]; + */ + protected $vcore_seconds = 0; + /** + * Optional. The cumulative memory usage of the application for a job, + * measured in mb-seconds. + * + * Generated from protobuf field int64 memory_mb_seconds = 6 [(.google.api.field_behavior) = OPTIONAL]; + */ + protected $memory_mb_seconds = 0; /** * Constructor. @@ -63,6 +77,12 @@ class YarnApplication extends \Google\Protobuf\Internal\Message * TimelineServer that provides application-specific information. The URL uses * the internal hostname, and requires a proxy server for resolution and, * possibly, access. + * @type int|string $vcore_seconds + * Optional. The cumulative CPU time consumed by the application for a job, + * measured in vcore-seconds. + * @type int|string $memory_mb_seconds + * Optional. The cumulative memory usage of the application for a job, + * measured in mb-seconds. * } */ public function __construct($data = NULL) { @@ -180,5 +200,61 @@ public function setTrackingUrl($var) return $this; } + /** + * Optional. The cumulative CPU time consumed by the application for a job, + * measured in vcore-seconds. + * + * Generated from protobuf field int64 vcore_seconds = 5 [(.google.api.field_behavior) = OPTIONAL]; + * @return int|string + */ + public function getVcoreSeconds() + { + return $this->vcore_seconds; + } + + /** + * Optional. The cumulative CPU time consumed by the application for a job, + * measured in vcore-seconds. + * + * Generated from protobuf field int64 vcore_seconds = 5 [(.google.api.field_behavior) = OPTIONAL]; + * @param int|string $var + * @return $this + */ + public function setVcoreSeconds($var) + { + GPBUtil::checkInt64($var); + $this->vcore_seconds = $var; + + return $this; + } + + /** + * Optional. The cumulative memory usage of the application for a job, + * measured in mb-seconds. + * + * Generated from protobuf field int64 memory_mb_seconds = 6 [(.google.api.field_behavior) = OPTIONAL]; + * @return int|string + */ + public function getMemoryMbSeconds() + { + return $this->memory_mb_seconds; + } + + /** + * Optional. The cumulative memory usage of the application for a job, + * measured in mb-seconds. + * + * Generated from protobuf field int64 memory_mb_seconds = 6 [(.google.api.field_behavior) = OPTIONAL]; + * @param int|string $var + * @return $this + */ + public function setMemoryMbSeconds($var) + { + GPBUtil::checkInt64($var); + $this->memory_mb_seconds = $var; + + return $this; + } + }