@@ -1209,6 +1209,31 @@ def update!(**args)
12091209 end
12101210 end
12111211
1212+ # Native Build Info
1213+ class BuildInfo
1214+ include Google ::Apis ::Core ::Hashable
1215+
1216+ # Optional. Build key.
1217+ # Corresponds to the JSON property `buildKey`
1218+ # @return [String]
1219+ attr_accessor :build_key
1220+
1221+ # Optional. Build value.
1222+ # Corresponds to the JSON property `buildValue`
1223+ # @return [String]
1224+ attr_accessor :build_value
1225+
1226+ def initialize ( **args )
1227+ update! ( **args )
1228+ end
1229+
1230+ # Update properties of this object
1231+ def update! ( **args )
1232+ @build_key = args [ :build_key ] if args . key? ( :build_key )
1233+ @build_value = args [ :build_value ] if args . key? ( :build_value )
1234+ end
1235+ end
1236+
12121237 # A request to cancel a job.
12131238 class CancelJobRequest
12141239 include Google ::Apis ::Core ::Hashable
@@ -2784,6 +2809,31 @@ def update!(**args)
27842809 end
27852810 end
27862811
2812+ # Native SQL Execution Data
2813+ class FallbackReason
2814+ include Google ::Apis ::Core ::Hashable
2815+
2816+ # Optional. Fallback node information.
2817+ # Corresponds to the JSON property `fallbackNode`
2818+ # @return [String]
2819+ attr_accessor :fallback_node
2820+
2821+ # Optional. Fallback to Spark reason.
2822+ # Corresponds to the JSON property `fallbackReason`
2823+ # @return [String]
2824+ attr_accessor :fallback_reason
2825+
2826+ def initialize ( **args )
2827+ update! ( **args )
2828+ end
2829+
2830+ # Update properties of this object
2831+ def update! ( **args )
2832+ @fallback_node = args [ :fallback_node ] if args . key? ( :fallback_node )
2833+ @fallback_reason = args [ :fallback_reason ] if args . key? ( :fallback_reason )
2834+ end
2835+ end
2836+
27872837 # A Dataproc job for running Apache Flink applications on YARN.
27882838 class FlinkJob
27892839 include Google ::Apis ::Core ::Hashable
@@ -2906,6 +2956,13 @@ class GceClusterConfig
29062956 # @return [Google::Apis::DataprocV1::ReservationAffinity]
29072957 attr_accessor :reservation_affinity
29082958
2959+ # Optional. Resource manager tags to add to all instances (see Resource manager
2960+ # tags resources (https://cloud.google.com/resource-manager/docs/tags/tags-
2961+ # creating-and-managing)).
2962+ # Corresponds to the JSON property `resourceManagerTags`
2963+ # @return [Hash<String,String>]
2964+ attr_accessor :resource_manager_tags
2965+
29092966 # Optional. The Dataproc service account (https://cloud.google.com/dataproc/docs/
29102967 # concepts/configuring-clusters/service-accounts#service_accounts_in_dataproc) (
29112968 # also see VM Data Plane identity (https://cloud.google.com/dataproc/docs/
@@ -2973,6 +3030,7 @@ def update!(**args)
29733030 @node_group_affinity = args [ :node_group_affinity ] if args . key? ( :node_group_affinity )
29743031 @private_ipv6_google_access = args [ :private_ipv6_google_access ] if args . key? ( :private_ipv6_google_access )
29753032 @reservation_affinity = args [ :reservation_affinity ] if args . key? ( :reservation_affinity )
3033+ @resource_manager_tags = args [ :resource_manager_tags ] if args . key? ( :resource_manager_tags )
29763034 @service_account = args [ :service_account ] if args . key? ( :service_account )
29773035 @service_account_scopes = args [ :service_account_scopes ] if args . key? ( :service_account_scopes )
29783036 @shielded_instance_config = args [ :shielded_instance_config ] if args . key? ( :shielded_instance_config )
@@ -5178,6 +5236,80 @@ def update!(**args)
51785236 end
51795237 end
51805238
5239+ #
5240+ class NativeBuildInfoUiData
5241+ include Google ::Apis ::Core ::Hashable
5242+
5243+ # Optional. Build class of Native.
5244+ # Corresponds to the JSON property `buildClass`
5245+ # @return [String]
5246+ attr_accessor :build_class
5247+
5248+ # Optional. Build related details.
5249+ # Corresponds to the JSON property `buildInfo`
5250+ # @return [Array<Google::Apis::DataprocV1::BuildInfo>]
5251+ attr_accessor :build_info
5252+
5253+ def initialize ( **args )
5254+ update! ( **args )
5255+ end
5256+
5257+ # Update properties of this object
5258+ def update! ( **args )
5259+ @build_class = args [ :build_class ] if args . key? ( :build_class )
5260+ @build_info = args [ :build_info ] if args . key? ( :build_info )
5261+ end
5262+ end
5263+
5264+ # Native SQL Execution Data
5265+ class NativeSqlExecutionUiData
5266+ include Google ::Apis ::Core ::Hashable
5267+
5268+ # Optional. Description of the execution.
5269+ # Corresponds to the JSON property `description`
5270+ # @return [String]
5271+ attr_accessor :description
5272+
5273+ # Required. Execution ID of the Native SQL Execution.
5274+ # Corresponds to the JSON property `executionId`
5275+ # @return [Fixnum]
5276+ attr_accessor :execution_id
5277+
5278+ # Optional. Description of the fallback.
5279+ # Corresponds to the JSON property `fallbackDescription`
5280+ # @return [String]
5281+ attr_accessor :fallback_description
5282+
5283+ # Optional. Fallback node to reason.
5284+ # Corresponds to the JSON property `fallbackNodeToReason`
5285+ # @return [Array<Google::Apis::DataprocV1::FallbackReason>]
5286+ attr_accessor :fallback_node_to_reason
5287+
5288+ # Optional. Number of nodes fallen back to Spark.
5289+ # Corresponds to the JSON property `numFallbackNodes`
5290+ # @return [Fixnum]
5291+ attr_accessor :num_fallback_nodes
5292+
5293+ # Optional. Number of nodes in Native.
5294+ # Corresponds to the JSON property `numNativeNodes`
5295+ # @return [Fixnum]
5296+ attr_accessor :num_native_nodes
5297+
5298+ def initialize ( **args )
5299+ update! ( **args )
5300+ end
5301+
5302+ # Update properties of this object
5303+ def update! ( **args )
5304+ @description = args [ :description ] if args . key? ( :description )
5305+ @execution_id = args [ :execution_id ] if args . key? ( :execution_id )
5306+ @fallback_description = args [ :fallback_description ] if args . key? ( :fallback_description )
5307+ @fallback_node_to_reason = args [ :fallback_node_to_reason ] if args . key? ( :fallback_node_to_reason )
5308+ @num_fallback_nodes = args [ :num_fallback_nodes ] if args . key? ( :num_fallback_nodes )
5309+ @num_native_nodes = args [ :num_native_nodes ] if args . key? ( :num_native_nodes )
5310+ end
5311+ end
5312+
51815313 # Dataproc Node Group. The Dataproc NodeGroup resource is not related to the
51825314 # Dataproc NodeGroupAffinity resource.
51835315 class NodeGroup
@@ -7420,7 +7552,7 @@ class Session
74207552 # @return [Hash<String,String>]
74217553 attr_accessor :labels
74227554
7423- # Required . The resource name of the session.
7555+ # Identifier . The resource name of the session.
74247556 # Corresponds to the JSON property `name`
74257557 # @return [String]
74267558 attr_accessor :name
@@ -8935,6 +9067,16 @@ class SparkWrapperObject
89359067 # @return [Google::Apis::DataprocV1::JobData]
89369068 attr_accessor :job_data
89379069
9070+ # Native Build Info
9071+ # Corresponds to the JSON property `nativeBuildInfoUiData`
9072+ # @return [Google::Apis::DataprocV1::NativeBuildInfoUiData]
9073+ attr_accessor :native_build_info_ui_data
9074+
9075+ # Native SQL Execution Data
9076+ # Corresponds to the JSON property `nativeSqlExecutionUiData`
9077+ # @return [Google::Apis::DataprocV1::NativeSqlExecutionUiData]
9078+ attr_accessor :native_sql_execution_ui_data
9079+
89389080 # Pool Data
89399081 # Corresponds to the JSON property `poolData`
89409082 # @return [Google::Apis::DataprocV1::PoolData]
@@ -9015,6 +9157,8 @@ def update!(**args)
90159157 @executor_stage_summary = args [ :executor_stage_summary ] if args . key? ( :executor_stage_summary )
90169158 @executor_summary = args [ :executor_summary ] if args . key? ( :executor_summary )
90179159 @job_data = args [ :job_data ] if args . key? ( :job_data )
9160+ @native_build_info_ui_data = args [ :native_build_info_ui_data ] if args . key? ( :native_build_info_ui_data )
9161+ @native_sql_execution_ui_data = args [ :native_sql_execution_ui_data ] if args . key? ( :native_sql_execution_ui_data )
90189162 @pool_data = args [ :pool_data ] if args . key? ( :pool_data )
90199163 @process_summary = args [ :process_summary ] if args . key? ( :process_summary )
90209164 @rdd_operation_graph = args [ :rdd_operation_graph ] if args . key? ( :rdd_operation_graph )
0 commit comments