@@ -2393,6 +2393,8 @@ def search_project_location_session_spark_application_executors(name, executor_s
2393
2393
# Required. The fully qualified name of the session to retrieve in the format "
2394
2394
# projects/PROJECT_ID/locations/DATAPROC_REGION/sessions/SESSION_ID/
2395
2395
# sparkApplications/APPLICATION_ID"
2396
+ # @param [Array<Fixnum>, Fixnum] job_ids
2397
+ # Optional. List of Job IDs to filter by if provided.
2396
2398
# @param [String] job_status
2397
2399
# Optional. List only jobs in the specific state.
2398
2400
# @param [Fixnum] page_size
@@ -2422,11 +2424,12 @@ def search_project_location_session_spark_application_executors(name, executor_s
2422
2424
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
2423
2425
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
2424
2426
# @raise [Google::Apis::AuthorizationError] Authorization is required
2425
- def search_project_location_session_spark_application_jobs ( name , job_status : nil , page_size : nil , page_token : nil , parent : nil , fields : nil , quota_user : nil , options : nil , &block )
2427
+ def search_project_location_session_spark_application_jobs ( name , job_ids : nil , job_status : nil , page_size : nil , page_token : nil , parent : nil , fields : nil , quota_user : nil , options : nil , &block )
2426
2428
command = make_simple_command ( :get , 'v1/{+name}:searchJobs' , options )
2427
2429
command . response_representation = Google ::Apis ::DataprocV1 ::SearchSessionSparkApplicationJobsResponse ::Representation
2428
2430
command . response_class = Google ::Apis ::DataprocV1 ::SearchSessionSparkApplicationJobsResponse
2429
2431
command . params [ 'name' ] = name unless name . nil?
2432
+ command . query [ 'jobIds' ] = job_ids unless job_ids . nil?
2430
2433
command . query [ 'jobStatus' ] = job_status unless job_status . nil?
2431
2434
command . query [ 'pageSize' ] = page_size unless page_size . nil?
2432
2435
command . query [ 'pageToken' ] = page_token unless page_token . nil?
@@ -2444,6 +2447,8 @@ def search_project_location_session_spark_application_jobs(name, job_status: nil
2444
2447
# @param [Boolean] details
2445
2448
# Optional. Lists/ hides details of Spark plan nodes. True is set to list and
2446
2449
# false to hide.
2450
+ # @param [Array<String>, String] operation_ids
2451
+ # Optional. List of Spark Connect operation IDs to filter by if provided.
2447
2452
# @param [Fixnum] page_size
2448
2453
# Optional. Maximum number of queries to return in each response. The service
2449
2454
# may return fewer than this. The default page size is 10; the maximum page size
@@ -2473,12 +2478,13 @@ def search_project_location_session_spark_application_jobs(name, job_status: nil
2473
2478
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
2474
2479
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
2475
2480
# @raise [Google::Apis::AuthorizationError] Authorization is required
2476
- def search_project_location_session_spark_application_sql_queries ( name , details : nil , page_size : nil , page_token : nil , parent : nil , plan_description : nil , fields : nil , quota_user : nil , options : nil , &block )
2481
+ def search_project_location_session_spark_application_sql_queries ( name , details : nil , operation_ids : nil , page_size : nil , page_token : nil , parent : nil , plan_description : nil , fields : nil , quota_user : nil , options : nil , &block )
2477
2482
command = make_simple_command ( :get , 'v1/{+name}:searchSqlQueries' , options )
2478
2483
command . response_representation = Google ::Apis ::DataprocV1 ::SearchSessionSparkApplicationSqlQueriesResponse ::Representation
2479
2484
command . response_class = Google ::Apis ::DataprocV1 ::SearchSessionSparkApplicationSqlQueriesResponse
2480
2485
command . params [ 'name' ] = name unless name . nil?
2481
2486
command . query [ 'details' ] = details unless details . nil?
2487
+ command . query [ 'operationIds' ] = operation_ids unless operation_ids . nil?
2482
2488
command . query [ 'pageSize' ] = page_size unless page_size . nil?
2483
2489
command . query [ 'pageToken' ] = page_token unless page_token . nil?
2484
2490
command . query [ 'parent' ] = parent unless parent . nil?
@@ -2615,6 +2621,8 @@ def search_project_location_session_spark_application_stage_attempts(name, page_
2615
2621
# subsequent page.
2616
2622
# @param [String] parent
2617
2623
# Required. Parent (Session) resource reference.
2624
+ # @param [Array<Fixnum>, Fixnum] stage_ids
2625
+ # Optional. List of Stage IDs to filter by if provided.
2618
2626
# @param [String] stage_status
2619
2627
# Optional. List only stages in the given state.
2620
2628
# @param [String] summary_metrics_mask
@@ -2639,14 +2647,15 @@ def search_project_location_session_spark_application_stage_attempts(name, page_
2639
2647
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
2640
2648
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
2641
2649
# @raise [Google::Apis::AuthorizationError] Authorization is required
2642
- def search_project_location_session_spark_application_stages ( name , page_size : nil , page_token : nil , parent : nil , stage_status : nil , summary_metrics_mask : nil , fields : nil , quota_user : nil , options : nil , &block )
2650
+ def search_project_location_session_spark_application_stages ( name , page_size : nil , page_token : nil , parent : nil , stage_ids : nil , stage_status : nil , summary_metrics_mask : nil , fields : nil , quota_user : nil , options : nil , &block )
2643
2651
command = make_simple_command ( :get , 'v1/{+name}:searchStages' , options )
2644
2652
command . response_representation = Google ::Apis ::DataprocV1 ::SearchSessionSparkApplicationStagesResponse ::Representation
2645
2653
command . response_class = Google ::Apis ::DataprocV1 ::SearchSessionSparkApplicationStagesResponse
2646
2654
command . params [ 'name' ] = name unless name . nil?
2647
2655
command . query [ 'pageSize' ] = page_size unless page_size . nil?
2648
2656
command . query [ 'pageToken' ] = page_token unless page_token . nil?
2649
2657
command . query [ 'parent' ] = parent unless parent . nil?
2658
+ command . query [ 'stageIds' ] = stage_ids unless stage_ids . nil?
2650
2659
command . query [ 'stageStatus' ] = stage_status unless stage_status . nil?
2651
2660
command . query [ 'summaryMetricsMask' ] = summary_metrics_mask unless summary_metrics_mask . nil?
2652
2661
command . query [ 'fields' ] = fields unless fields . nil?
0 commit comments