Skip to content

Commit b75dac6

Browse files
chore: generate libraries at Tue Jun 2 03:05:29 UTC 2026
1 parent 6078c7a commit b75dac6

10 files changed

Lines changed: 462 additions & 131 deletions

File tree

java-dataproc/google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/JobControllerClient.java

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -744,12 +744,15 @@ public final ListJobsPagedResponse listJobs(String projectId, String region) {
744744
* @param filter Optional. A filter constraining the jobs to list. Filters are case-sensitive and
745745
* have the following syntax:
746746
* <p>[field = value] AND [field [= value]] ...
747-
* <p>where &#42;&#42;field&#42;&#42; is `status.state` or `labels.[KEY]`, and `[KEY]` is a
748-
* label key. &#42;&#42;value&#42;&#42; can be `&#42;` to match all values. `status.state` can
749-
* be either `ACTIVE` or `NON_ACTIVE`. Only the logical `AND` operator is supported;
750-
* space-separated items are treated as having an implicit `AND` operator.
747+
* <p>where &#42;&#42;field&#42;&#42; is `status.state` or `insertTime`, or `labels.[KEY]`,
748+
* and `[KEY]` is a label key. &#42;&#42;value&#42;&#42; can be `&#42;` to match all values.
749+
* `status.state` can be either `ACTIVE` or `NON_ACTIVE`. Allows `insertTime` to be a
750+
* timestamp in RFC 3339 format in double quotes, such as `2025-01-01T00:00:00Z`. Only the
751+
* logical `AND` operator is supported; space-separated items are treated as having an
752+
* implicit `AND` operator.
751753
* <p>Example filter:
752-
* <p>status.state = ACTIVE AND labels.env = staging AND labels.starred = &#42;
754+
* <p>status.state = ACTIVE AND labels.env = staging AND labels.starred = &#42; AND insertTime
755+
* &lt;= "2025-01-01T00:00:00Z"
753756
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
754757
*/
755758
public final ListJobsPagedResponse listJobs(String projectId, String region, String filter) {

java-dataproc/proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/JobsProto.java

Lines changed: 62 additions & 59 deletions
Original file line numberDiff line numberDiff line change
@@ -431,17 +431,20 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
431431
+ "\014STALE_STATUS\020\003\"<\n"
432432
+ "\014JobReference\022\027\n\n"
433433
+ "project_id\030\001 \001(\tB\003\340A\001\022\023\n"
434-
+ "\006job_id\030\002 \001(\tB\003\340A\001\"\245\002\n"
434+
+ "\006job_id\030\002 \001(\tB\003\340A\001\"\341\002\n"
435435
+ "\017YarnApplication\022\021\n"
436436
+ "\004name\030\001 \001(\tB\003\340A\002\022C\n"
437437
+ "\005state\030\002"
438438
+ " \001(\0162/.google.cloud.dataproc.v1.YarnApplication.StateB\003\340A\002\022\025\n"
439439
+ "\010progress\030\003 \001(\002B\003\340A\002\022\031\n"
440-
+ "\014tracking_url\030\004 \001(\tB\003\340A\001\"\207\001\n"
440+
+ "\014tracking_url\030\004 \001(\tB\003\340A\001\022\032\n\r"
441+
+ "vcore_seconds\030\005 \001(\003B\003\340A\001\022\036\n"
442+
+ "\021memory_mb_seconds\030\006 \001(\003B\003\340A\001\"\207\001\n"
441443
+ "\005State\022\025\n"
442444
+ "\021STATE_UNSPECIFIED\020\000\022\007\n"
443445
+ "\003NEW\020\001\022\016\n\n"
444-
+ "NEW_SAVING\020\002\022\r\n"
446+
+ "NEW_SAVING\020\002\022\r"
447+
+ "\n"
445448
+ "\tSUBMITTED\020\003\022\014\n"
446449
+ "\010ACCEPTED\020\004\022\013\n"
447450
+ "\007RUNNING\020\005\022\014\n"
@@ -453,41 +456,41 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
453456
+ " \001(\0132&.google.cloud.dataproc.v1.JobReferenceB\003\340A\001\022>\n"
454457
+ "\tplacement\030\002"
455458
+ " \001(\0132&.google.cloud.dataproc.v1.JobPlacementB\003\340A\002\022>\n\n"
456-
+ "hadoop_job\030\003"
457-
+ " \001(\0132#.google.cloud.dataproc.v1.HadoopJobB\003\340A\001H\000\022<\n"
458-
+ "\tspark_job\030\004 \001(\0132\"."
459-
+ "google.cloud.dataproc.v1.SparkJobB\003\340A\001H\000\022@\n"
460-
+ "\013pyspark_job\030\005"
461-
+ " \001(\0132$.google.cloud.dataproc.v1.PySparkJobB\003\340A\001H\000\022:\n"
459+
+ "hadoop_job\030\003 \001(\0132#.goo"
460+
+ "gle.cloud.dataproc.v1.HadoopJobB\003\340A\001H\000\022<\n"
461+
+ "\tspark_job\030\004"
462+
+ " \001(\0132\".google.cloud.dataproc.v1.SparkJobB\003\340A\001H\000\022@\n"
463+
+ "\013pyspark_job\030\005 \001("
464+
+ "\0132$.google.cloud.dataproc.v1.PySparkJobB\003\340A\001H\000\022:\n"
462465
+ "\010hive_job\030\006"
463466
+ " \001(\0132!.google.cloud.dataproc.v1.HiveJobB\003\340A\001H\000\0228\n"
464467
+ "\007pig_job\030\007 \001(\0132"
465468
+ " .google.cloud.dataproc.v1.PigJobB\003\340A\001H\000\022?\n"
466469
+ "\013spark_r_job\030\025"
467470
+ " \001(\0132#.google.cloud.dataproc.v1.SparkRJobB\003\340A\001H\000\022C\n\r"
468-
+ "spark_sql_job\030\014 \001(\0132%.googl"
469-
+ "e.cloud.dataproc.v1.SparkSqlJobB\003\340A\001H\000\022>\n\n"
470-
+ "presto_job\030\027"
471-
+ " \001(\0132#.google.cloud.dataproc.v1.PrestoJobB\003\340A\001H\000\022<\n"
472-
+ "\ttrino_job\030\034 \001("
473-
+ "\0132\".google.cloud.dataproc.v1.TrinoJobB\003\340A\001H\000\022<\n"
474-
+ "\tflink_job\030\035"
475-
+ " \001(\0132\".google.cloud.dataproc.v1.FlinkJobB\003\340A\001H\000\0228\n"
471+
+ "spark_sql_job\030\014"
472+
+ " \001(\0132%.google.cloud.dataproc.v1.SparkSqlJobB\003\340A\001H\000\022>\n\n"
473+
+ "presto_job\030\027 \001(\0132#"
474+
+ ".google.cloud.dataproc.v1.PrestoJobB\003\340A\001H\000\022<\n"
475+
+ "\ttrino_job\030\034"
476+
+ " \001(\0132\".google.cloud.dataproc.v1.TrinoJobB\003\340A\001H\000\022<\n"
477+
+ "\tflink_job\030\035 "
478+
+ "\001(\0132\".google.cloud.dataproc.v1.FlinkJobB\003\340A\001H\000\0228\n"
476479
+ "\006status\030\010 \001(\0132#.google.cloud.dataproc.v1.JobStatusB\003\340A\003\022@\n"
477480
+ "\016status_history\030\r"
478481
+ " \003(\0132#.google.cloud.dataproc.v1.JobStatusB\003\340A\003\022I\n"
479-
+ "\021yarn_applications\030\t"
480-
+ " \003(\0132).google.cloud.dataproc.v1.YarnApplicationB\003\340A\003\022\'\n"
482+
+ "\021yarn_applications\030\t \003(\0132)."
483+
+ "google.cloud.dataproc.v1.YarnApplicationB\003\340A\003\022\'\n"
481484
+ "\032driver_output_resource_uri\030\021 \001(\tB\003\340A\003\022%\n"
482485
+ "\030driver_control_files_uri\030\017 \001(\tB\003\340A\003\022>\n"
483-
+ "\006labels\030\022 \003("
484-
+ "\0132).google.cloud.dataproc.v1.Job.LabelsEntryB\003\340A\001\022@\n\n"
486+
+ "\006labels\030\022"
487+
+ " \003(\0132).google.cloud.dataproc.v1.Job.LabelsEntryB\003\340A\001\022@\n\n"
485488
+ "scheduling\030\024"
486489
+ " \001(\0132\'.google.cloud.dataproc.v1.JobSchedulingB\003\340A\001\022\025\n"
487490
+ "\010job_uuid\030\026 \001(\tB\003\340A\003\022\021\n"
488491
+ "\004done\030\030 \001(\010B\003\340A\003\022W\n"
489-
+ "\030driver_scheduling_config\030\033 \001(\01320.google"
490-
+ ".cloud.dataproc.v1.DriverSchedulingConfigB\003\340A\001\032-\n"
492+
+ "\030driver_scheduling_config\030\033"
493+
+ " \001(\01320.google.cloud.dataproc.v1.DriverSchedulingConfigB\003\340A\001\032-\n"
491494
+ "\013LabelsEntry\022\013\n"
492495
+ "\003key\030\001 \001(\t\022\r\n"
493496
+ "\005value\030\002 \001(\t:\0028\001B\n\n"
@@ -505,12 +508,11 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
505508
+ "request_id\030\004 \001(\tB\003\340A\001\"\256\001\n"
506509
+ "\013JobMetadata\022\023\n"
507510
+ "\006job_id\030\001 \001(\tB\003\340A\003\0228\n"
508-
+ "\006status\030\002"
509-
+ " \001(\0132#.google.cloud.dataproc.v1.JobStatusB\003\340A\003\022\033\n"
511+
+ "\006status\030\002 \001(\0132#.g"
512+
+ "oogle.cloud.dataproc.v1.JobStatusB\003\340A\003\022\033\n"
510513
+ "\016operation_type\030\003 \001(\tB\003\340A\003\0223\n\n"
511514
+ "start_time\030\004 \001(\0132\032.google.protobuf.TimestampB\003\340A\003\"R\n\r"
512-
+ "GetJobRequest\022\027\n"
513-
+ "\n"
515+
+ "GetJobRequest\022\027\n\n"
514516
+ "project_id\030\001 \001(\tB\003\340A\002\022\023\n"
515517
+ "\006region\030\003 \001(\tB\003\340A\002\022\023\n"
516518
+ "\006job_id\030\002 \001(\tB\003\340A\002\"\263\002\n"
@@ -520,8 +522,8 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
520522
+ "\tpage_size\030\002 \001(\005B\003\340A\001\022\027\n\n"
521523
+ "page_token\030\003 \001(\tB\003\340A\001\022\031\n"
522524
+ "\014cluster_name\030\004 \001(\tB\003\340A\001\022Y\n"
523-
+ "\021job_state_matcher\030\005 \001(\01629.goog"
524-
+ "le.cloud.dataproc.v1.ListJobsRequest.JobStateMatcherB\003\340A\001\022\023\n"
525+
+ "\021job_state_matcher\030\005"
526+
+ " \001(\01629.google.cloud.dataproc.v1.ListJobsRequest.JobStateMatcherB\003\340A\001\022\023\n"
525527
+ "\006filter\030\007 \001(\tB\003\340A\001\"6\n"
526528
+ "\017JobStateMatcher\022\007\n"
527529
+ "\003ALL\020\000\022\n\n"
@@ -546,35 +548,36 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
546548
+ "\006region\030\003 \001(\tB\003\340A\002\022\023\n"
547549
+ "\006job_id\030\002 \001(\tB\003\340A\0022\374\n\n\r"
548550
+ "JobController\022\261\001\n"
549-
+ "\tSubmitJob\022*.google.cloud.dataproc.v1.SubmitJobRequest\032\035.google.cloud.dat"
550-
+ "aproc.v1.Job\"Y\332A\025project_id,region,job\202\323"
551-
+ "\344\223\002;\"6/v1/projects/{project_id}/regions/{region}/jobs:submit:\001*\022\336\001\n"
552-
+ "\024SubmitJobAsOperation\022*.google.cloud.dataproc.v1.Subm"
553-
+ "itJobRequest\032\035.google.longrunning.Operation\"{\312A\022\n"
554-
+ "\003Job\022\013JobMetadata\332A\027project_id, region,"
555-
+ " job\202\323\344\223\002F\"A/v1/projects/{projec"
556-
+ "t_id}/regions/{region}/jobs:submitAsOperation:\001*\022\255\001\n"
557-
+ "\006GetJob\022\'.google.cloud.dataproc.v1.GetJobRequest\032\035.google.cloud.data"
558-
+ "proc.v1.Job\"[\332A\030project_id,region,job_id"
559-
+ "\202\323\344\223\002:\0228/v1/projects/{project_id}/regions/{region}/jobs/{job_id}\022\311\001\n"
560-
+ "\010ListJobs\022).google.cloud.dataproc.v1.ListJobsRequest"
561-
+ "\032*.google.cloud.dataproc.v1.ListJobsResp"
562-
+ "onse\"f\332A\021project_id,region\332A\030project_id,"
563-
+ "region,filter\202\323\344\223\0021\022//v1/projects/{project_id}/regions/{region}/jobs\022\235\001\n"
564-
+ "\tUpdateJob\022*.google.cloud.dataproc.v1.UpdateJobR"
565-
+ "equest\032\035.google.cloud.dataproc.v1.Job\"E\202"
566-
+ "\323\344\223\002?28/v1/projects/{project_id}/regions/{region}/jobs/{job_id}:\003job\022\275\001\n"
567-
+ "\tCancelJob\022*.google.cloud.dataproc.v1.CancelJobR"
568-
+ "equest\032\035.google.cloud.dataproc.v1.Job\"e\332"
569-
+ "A\030project_id,region,job_id\202\323\344\223\002D\"?/v1/pr"
570-
+ "ojects/{project_id}/regions/{region}/jobs/{job_id}:cancel:\001*\022\254\001\n"
571-
+ "\tDeleteJob\022*.google.cloud.dataproc.v1.DeleteJobRequest\032\026"
572-
+ ".google.protobuf.Empty\"[\332A\030project_id,re"
573-
+ "gion,job_id\202\323\344\223\002:*8/v1/projects/{project"
574-
+ "_id}/regions/{region}/jobs/{job_id}\032K\312A\027"
575-
+ "dataproc.googleapis.com\322A.https://www.googleapis.com/auth/cloud-platformBh\n"
576-
+ "\034com.google.cloud.dataproc.v1B\tJobsProtoP\001Z;c"
577-
+ "loud.google.com/go/dataproc/v2/apiv1/dataprocpb;dataprocpbb\006proto3"
551+
+ "\tSubmitJob\022*.google.cloud.dataproc.v1.SubmitJobReques"
552+
+ "t\032\035.google.cloud.dataproc.v1.Job\"Y\332A\025pro"
553+
+ "ject_id,region,job\202\323\344\223\002;\"6/v1/projects/{"
554+
+ "project_id}/regions/{region}/jobs:submit:\001*\022\336\001\n"
555+
+ "\024SubmitJobAsOperation\022*.google.cl"
556+
+ "oud.dataproc.v1.SubmitJobRequest\032\035.google.longrunning.Operation\"{\312A\022\n"
557+
+ "\003Job\022\013JobMetadata\332A\027project_id, region, job\202\323\344\223\002F\"A"
558+
+ "/v1/projects/{project_id}/regions/{region}/jobs:submitAsOperation:\001*\022\255\001\n"
559+
+ "\006GetJob\022\'.google.cloud.dataproc.v1.GetJobRequest"
560+
+ "\032\035.google.cloud.dataproc.v1.Job\"[\332A\030proj"
561+
+ "ect_id,region,job_id\202\323\344\223\002:\0228/v1/projects"
562+
+ "/{project_id}/regions/{region}/jobs/{job_id}\022\311\001\n"
563+
+ "\010ListJobs\022).google.cloud.dataproc.v1.ListJobsRequest\032*.google.cloud.data"
564+
+ "proc.v1.ListJobsResponse\"f\332A\021project_id,"
565+
+ "region\332A\030project_id,region,filter\202\323\344\223\0021\022"
566+
+ "//v1/projects/{project_id}/regions/{region}/jobs\022\235\001\n"
567+
+ "\tUpdateJob\022*.google.cloud.dataproc.v1.UpdateJobRequest\032\035.google.clou"
568+
+ "d.dataproc.v1.Job\"E\202\323\344\223\002?28/v1/projects/"
569+
+ "{project_id}/regions/{region}/jobs/{job_id}:\003job\022\275\001\n"
570+
+ "\tCancelJob\022*.google.cloud.dataproc.v1.CancelJobRequest\032\035.google.clou"
571+
+ "d.dataproc.v1.Job\"e\332A\030project_id,region,"
572+
+ "job_id\202\323\344\223\002D\"?/v1/projects/{project_id}/"
573+
+ "regions/{region}/jobs/{job_id}:cancel:\001*\022\254\001\n"
574+
+ "\tDeleteJob\022*.google.cloud.dataproc.v1.DeleteJobRequest\032\026.google.protobuf.Emp"
575+
+ "ty\"[\332A\030project_id,region,job_id\202\323\344\223\002:*8/"
576+
+ "v1/projects/{project_id}/regions/{region"
577+
+ "}/jobs/{job_id}\032K\312A\027dataproc.googleapis."
578+
+ "com\322A.https://www.googleapis.com/auth/cloud-platformBh\n"
579+
+ "\034com.google.cloud.dataproc.v1B\tJobsProtoP\001Z;cloud.google.com/go/d"
580+
+ "ataproc/v2/apiv1/dataprocpb;dataprocpbb\006proto3"
578581
};
579582
descriptor =
580583
com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
@@ -895,7 +898,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
895898
new com.google.protobuf.GeneratedMessage.FieldAccessorTable(
896899
internal_static_google_cloud_dataproc_v1_YarnApplication_descriptor,
897900
new java.lang.String[] {
898-
"Name", "State", "Progress", "TrackingUrl",
901+
"Name", "State", "Progress", "TrackingUrl", "VcoreSeconds", "MemoryMbSeconds",
899902
});
900903
internal_static_google_cloud_dataproc_v1_Job_descriptor = getDescriptor().getMessageType(16);
901904
internal_static_google_cloud_dataproc_v1_Job_fieldAccessorTable =

0 commit comments

Comments
 (0)