v1alpha1

type AutoscalingPolicy struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              AutoscalingPolicySpec   `json:"spec,omitempty"`
	Status            AutoscalingPolicyStatus `json:"status,omitempty"`
}

type AutoscalingPolicyList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of AutoscalingPolicy CRD objects
	Items []AutoscalingPolicy `json:"items,omitempty"`
}

type AutoscalingPolicySpec struct {
	State *AutoscalingPolicySpecResource `json:"state,omitempty" tf:"-"`

	Resource AutoscalingPolicySpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

type AutoscalingPolicySpecBasicAlgorithm struct {
	// Duration between scaling events. A scaling period starts after the
	// update operation from the previous event has completed.
	//
	// Bounds: [2m, 1d]. Default: 2m.
	// +optional
	CooldownPeriod *string `json:"cooldownPeriod,omitempty" tf:"cooldown_period"`
	// YARN autoscaling configuration.
	YarnConfig *AutoscalingPolicySpecBasicAlgorithmYarnConfig `json:"yarnConfig" tf:"yarn_config"`
}

type AutoscalingPolicySpecBasicAlgorithmCodec struct {
}

type AutoscalingPolicySpecBasicAlgorithmYarnConfig struct {
	// Timeout for YARN graceful decommissioning of Node Managers. Specifies the
	// duration to wait for jobs to complete before forcefully removing workers
	// (and potentially interrupting jobs). Only applicable to downscaling operations.
	//
	// Bounds: [0s, 1d].
	GracefulDecommissionTimeout *string `json:"gracefulDecommissionTimeout" tf:"graceful_decommission_timeout"`
	// Fraction of average pending memory in the last cooldown period for which to
	// remove workers. A scale-down factor of 1 will result in scaling down so that there
	// is no available memory remaining after the update (more aggressive scaling).
	// A scale-down factor of 0 disables removing workers, which can be beneficial for
	// autoscaling a single job.
	//
	// Bounds: [0.0, 1.0].
	ScaleDownFactor *float64 `json:"scaleDownFactor" tf:"scale_down_factor"`
	// Minimum scale-down threshold as a fraction of total cluster size before scaling occurs.
	// For example, in a 20-worker cluster, a threshold of 0.1 means the autoscaler must
	// recommend at least a 2 worker scale-down for the cluster to scale. A threshold of 0
	// means the autoscaler will scale down on any recommended change.
	//
	// Bounds: [0.0, 1.0]. Default: 0.0.
	// +optional
	ScaleDownMinWorkerFraction *float64 `json:"scaleDownMinWorkerFraction,omitempty" tf:"scale_down_min_worker_fraction"`
	// Fraction of average pending memory in the last cooldown period for which to
	// add workers. A scale-up factor of 1.0 will result in scaling up so that there
	// is no pending memory remaining after the update (more aggressive scaling).
	// A scale-up factor closer to 0 will result in a smaller magnitude of scaling up
	// (less aggressive scaling).
	//
	// Bounds: [0.0, 1.0].
	ScaleUpFactor *float64 `json:"scaleUpFactor" tf:"scale_up_factor"`
	// Minimum scale-up threshold as a fraction of total cluster size before scaling
	// occurs. For example, in a 20-worker cluster, a threshold of 0.1 means the autoscaler
	// must recommend at least a 2-worker scale-up for the cluster to scale. A threshold of
	// 0 means the autoscaler will scale up on any recommended change.
	//
	// Bounds: [0.0, 1.0]. Default: 0.0.
	// +optional
	ScaleUpMinWorkerFraction *float64 `json:"scaleUpMinWorkerFraction,omitempty" tf:"scale_up_min_worker_fraction"`
}

type AutoscalingPolicySpecBasicAlgorithmYarnConfigCodec struct {
}

type AutoscalingPolicySpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// Basic algorithm for autoscaling.
	// +optional
	BasicAlgorithm *AutoscalingPolicySpecBasicAlgorithm `json:"basicAlgorithm,omitempty" tf:"basic_algorithm"`
	// The  location where the autoscaling policy should reside.
	// The default value is 'global'.
	// +optional
	Location *string `json:"location,omitempty" tf:"location"`
	// The "resource name" of the autoscaling policy.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// The policy id. The id must contain only letters (a-z, A-Z), numbers (0-9), underscores (_),
	// and hyphens (-). Cannot begin or end with underscore or hyphen. Must consist of between
	// 3 and 50 characters.
	PolicyID *string `json:"policyID" tf:"policy_id"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// Describes how the autoscaler will operate for secondary workers.
	// +optional
	SecondaryWorkerConfig *AutoscalingPolicySpecSecondaryWorkerConfig `json:"secondaryWorkerConfig,omitempty" tf:"secondary_worker_config"`
	// Describes how the autoscaler will operate for primary workers.
	// +optional
	WorkerConfig *AutoscalingPolicySpecWorkerConfig `json:"workerConfig,omitempty" tf:"worker_config"`
}

type AutoscalingPolicySpecSecondaryWorkerConfig struct {
	// Maximum number of instances for this group. Note that by default, clusters will not use
	// secondary workers. Required for secondary workers if the minimum secondary instances is set.
	// Bounds: [minInstances, ). Defaults to 0.
	// +optional
	MaxInstances *int64 `json:"maxInstances,omitempty" tf:"max_instances"`
	// Minimum number of instances for this group. Bounds: [0, maxInstances]. Defaults to 0.
	// +optional
	MinInstances *int64 `json:"minInstances,omitempty" tf:"min_instances"`
	// Weight for the instance group, which is used to determine the fraction of total workers
	// in the cluster from this instance group. For example, if primary workers have weight 2,
	// and secondary workers have weight 1, the cluster will have approximately 2 primary workers
	// for each secondary worker.
	//
	// The cluster may not reach the specified balance if constrained by min/max bounds or other
	// autoscaling settings. For example, if maxInstances for secondary workers is 0, then only
	// primary workers will be added. The cluster can also be out of balance when created.
	//
	// If weight is not set on any instance group, the cluster will default to equal weight for
	// all groups: the cluster will attempt to maintain an equal number of workers in each group
	// within the configured size bounds for each group. If weight is set for one group only,
	// the cluster will default to zero weight on the unset group. For example if weight is set
	// only on primary workers, the cluster will use primary workers only and no secondary workers.
	// +optional
	Weight *int64 `json:"weight,omitempty" tf:"weight"`
}

type AutoscalingPolicySpecSecondaryWorkerConfigCodec struct {
}

type AutoscalingPolicySpecWorkerConfig struct {
	// Maximum number of instances for this group.
	MaxInstances *int64 `json:"maxInstances" tf:"max_instances"`
	// Minimum number of instances for this group. Bounds: [2, maxInstances]. Defaults to 2.
	// +optional
	MinInstances *int64 `json:"minInstances,omitempty" tf:"min_instances"`
	// Weight for the instance group, which is used to determine the fraction of total workers
	// in the cluster from this instance group. For example, if primary workers have weight 2,
	// and secondary workers have weight 1, the cluster will have approximately 2 primary workers
	// for each secondary worker.
	//
	// The cluster may not reach the specified balance if constrained by min/max bounds or other
	// autoscaling settings. For example, if maxInstances for secondary workers is 0, then only
	// primary workers will be added. The cluster can also be out of balance when created.
	//
	// If weight is not set on any instance group, the cluster will default to equal weight for
	// all groups: the cluster will attempt to maintain an equal number of workers in each group
	// within the configured size bounds for each group. If weight is set for one group only,
	// the cluster will default to zero weight on the unset group. For example if weight is set
	// only on primary workers, the cluster will use primary workers only and no secondary workers.
	// +optional
	Weight *int64 `json:"weight,omitempty" tf:"weight"`
}

type AutoscalingPolicySpecWorkerConfigCodec struct {
}

type AutoscalingPolicyStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

type Cluster struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ClusterSpec   `json:"spec,omitempty"`
	Status            ClusterStatus `json:"status,omitempty"`
}

type ClusterIamBinding struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ClusterIamBindingSpec   `json:"spec,omitempty"`
	Status            ClusterIamBindingStatus `json:"status,omitempty"`
}

type ClusterIamBindingList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of ClusterIamBinding CRD objects
	Items []ClusterIamBinding `json:"items,omitempty"`
}

type ClusterIamBindingSpec struct {
	State *ClusterIamBindingSpecResource `json:"state,omitempty" tf:"-"`

	Resource ClusterIamBindingSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

type ClusterIamBindingSpecCondition struct {
	// +optional
	Description *string `json:"description,omitempty" tf:"description"`
	Expression  *string `json:"expression" tf:"expression"`
	Title       *string `json:"title" tf:"title"`
}

type ClusterIamBindingSpecConditionCodec struct {
}

type ClusterIamBindingSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	Cluster *string `json:"cluster" tf:"cluster"`
	// +optional
	Condition *ClusterIamBindingSpecCondition `json:"condition,omitempty" tf:"condition"`
	// +optional
	Etag    *string  `json:"etag,omitempty" tf:"etag"`
	Members []string `json:"members" tf:"members"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// +optional
	Region *string `json:"region,omitempty" tf:"region"`
	Role   *string `json:"role" tf:"role"`
}

type ClusterIamBindingStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

type ClusterIamMember struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ClusterIamMemberSpec   `json:"spec,omitempty"`
	Status            ClusterIamMemberStatus `json:"status,omitempty"`
}

type ClusterIamMemberList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of ClusterIamMember CRD objects
	Items []ClusterIamMember `json:"items,omitempty"`
}

type ClusterIamMemberSpec struct {
	State *ClusterIamMemberSpecResource `json:"state,omitempty" tf:"-"`

	Resource ClusterIamMemberSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

type ClusterIamMemberSpecCondition struct {
	// +optional
	Description *string `json:"description,omitempty" tf:"description"`
	Expression  *string `json:"expression" tf:"expression"`
	Title       *string `json:"title" tf:"title"`
}

type ClusterIamMemberSpecConditionCodec struct {
}

type ClusterIamMemberSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	Cluster *string `json:"cluster" tf:"cluster"`
	// +optional
	Condition *ClusterIamMemberSpecCondition `json:"condition,omitempty" tf:"condition"`
	// +optional
	Etag   *string `json:"etag,omitempty" tf:"etag"`
	Member *string `json:"member" tf:"member"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// +optional
	Region *string `json:"region,omitempty" tf:"region"`
	Role   *string `json:"role" tf:"role"`
}

type ClusterIamMemberStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

type ClusterIamPolicy struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ClusterIamPolicySpec   `json:"spec,omitempty"`
	Status            ClusterIamPolicyStatus `json:"status,omitempty"`
}

type ClusterIamPolicyList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of ClusterIamPolicy CRD objects
	Items []ClusterIamPolicy `json:"items,omitempty"`
}

type ClusterIamPolicySpec struct {
	State *ClusterIamPolicySpecResource `json:"state,omitempty" tf:"-"`

	Resource ClusterIamPolicySpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

type ClusterIamPolicySpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	Cluster *string `json:"cluster" tf:"cluster"`
	// +optional
	Etag       *string `json:"etag,omitempty" tf:"etag"`
	PolicyData *string `json:"policyData" tf:"policy_data"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// +optional
	Region *string `json:"region,omitempty" tf:"region"`
}

type ClusterIamPolicyStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

type ClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of Cluster CRD objects
	Items []Cluster `json:"items,omitempty"`
}

type ClusterSpec struct {
	State *ClusterSpecResource `json:"state,omitempty" tf:"-"`

	Resource ClusterSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

type ClusterSpecClusterConfig struct {
	// The autoscaling policy config associated with the cluster.
	// +optional
	AutoscalingConfig *ClusterSpecClusterConfigAutoscalingConfig `json:"autoscalingConfig,omitempty" tf:"autoscaling_config"`
	//  The name of the cloud storage bucket ultimately used to house the staging data for the cluster. If staging_bucket is specified, it will contain this value, otherwise it will be the auto generated name.
	// +optional
	Bucket *string `json:"bucket,omitempty" tf:"bucket"`
	// The Customer managed encryption keys settings for the cluster.
	// +optional
	EncryptionConfig *ClusterSpecClusterConfigEncryptionConfig `json:"encryptionConfig,omitempty" tf:"encryption_config"`
	// Common config settings for resources of Google Compute Engine cluster instances, applicable to all instances in the cluster.
	// +optional
	GceClusterConfig *ClusterSpecClusterConfigGceClusterConfig `json:"gceClusterConfig,omitempty" tf:"gce_cluster_config"`
	// Commands to execute on each node after config is completed. You can specify multiple versions of these.
	// +optional
	InitializationAction []ClusterSpecClusterConfigInitializationAction `json:"initializationAction,omitempty" tf:"initialization_action"`
	// The Google Compute Engine config settings for the master/worker instances in a cluster.
	// +optional
	MasterConfig *ClusterSpecClusterConfigMasterConfig `json:"masterConfig,omitempty" tf:"master_config"`
	// The Google Compute Engine config settings for the additional (aka preemptible) instances in a cluster.
	// +optional
	PreemptibleWorkerConfig *ClusterSpecClusterConfigPreemptibleWorkerConfig `json:"preemptibleWorkerConfig,omitempty" tf:"preemptible_worker_config"`
	// Security related configuration.
	// +optional
	SecurityConfig *ClusterSpecClusterConfigSecurityConfig `json:"securityConfig,omitempty" tf:"security_config"`
	// The config settings for software inside the cluster.
	// +optional
	SoftwareConfig *ClusterSpecClusterConfigSoftwareConfig `json:"softwareConfig,omitempty" tf:"software_config"`
	// The Cloud Storage staging bucket used to stage files, such as Hadoop jars, between client machines and the cluster. Note: If you don't explicitly specify a staging_bucket then GCP will auto create / assign one for you. However, you are not guaranteed an auto generated bucket which is solely dedicated to your cluster; it may be shared with other clusters in the same region/zone also choosing to use the auto generation option.
	// +optional
	StagingBucket *string `json:"stagingBucket,omitempty" tf:"staging_bucket"`
	// The Cloud Storage temp bucket used to store ephemeral cluster and jobs data, such as Spark and MapReduce history files. Note: If you don't explicitly specify a temp_bucket then GCP will auto create / assign one for you.
	// +optional
	TempBucket *string `json:"tempBucket,omitempty" tf:"temp_bucket"`
	// The Google Compute Engine config settings for the master/worker instances in a cluster.
	// +optional
	WorkerConfig *ClusterSpecClusterConfigWorkerConfig `json:"workerConfig,omitempty" tf:"worker_config"`
}

type ClusterSpecClusterConfigAutoscalingConfig struct {
	// The autoscaling policy used by the cluster.
	PolicyURI *string `json:"policyURI" tf:"policy_uri"`
}

type ClusterSpecClusterConfigAutoscalingConfigCodec struct {
}

type ClusterSpecClusterConfigCodec struct {
}

type ClusterSpecClusterConfigEncryptionConfig struct {
	// The Cloud KMS key name to use for PD disk encryption for all instances in the cluster.
	KmsKeyName *string `json:"kmsKeyName" tf:"kms_key_name"`
}

type ClusterSpecClusterConfigEncryptionConfigCodec struct {
}

type ClusterSpecClusterConfigGceClusterConfig struct {
	// By default, clusters are not restricted to internal IP addresses, and will have ephemeral external IP addresses assigned to each instance. If set to true, all instances in the cluster will only have internal IP addresses. Note: Private Google Access (also known as privateIpGoogleAccess) must be enabled on the subnetwork that the cluster will be launched in.
	// +optional
	InternalIPOnly *bool `json:"internalIPOnly,omitempty" tf:"internal_ip_only"`
	// A map of the Compute Engine metadata entries to add to all instances
	// +optional
	Metadata *map[string]string `json:"metadata,omitempty" tf:"metadata"`
	// The name or self_link of the Google Compute Engine network to the cluster will be part of. Conflicts with subnetwork. If neither is specified, this defaults to the "default" network.
	// +optional
	Network *string `json:"network,omitempty" tf:"network"`
	// The service account to be used by the Node VMs. If not specified, the "default" service account is used.
	// +optional
	ServiceAccount *string `json:"serviceAccount,omitempty" tf:"service_account"`
	// The set of Google API scopes to be made available on all of the node VMs under the service_account specified. These can be either FQDNs, or scope aliases.
	// +optional
	ServiceAccountScopes []string `json:"serviceAccountScopes,omitempty" tf:"service_account_scopes"`
	// Shielded Instance Config for clusters using Compute Engine Shielded VMs.
	// +optional
	ShieldedInstanceConfig *ClusterSpecClusterConfigGceClusterConfigShieldedInstanceConfig `json:"shieldedInstanceConfig,omitempty" tf:"shielded_instance_config"`
	// The name or self_link of the Google Compute Engine subnetwork the cluster will be part of. Conflicts with network.
	// +optional
	Subnetwork *string `json:"subnetwork,omitempty" tf:"subnetwork"`
	// The list of instance tags applied to instances in the cluster. Tags are used to identify valid sources or targets for network firewalls.
	// +optional
	Tags []string `json:"tags,omitempty" tf:"tags"`
	// The GCP zone where your data is stored and used (i.e. where the master and the worker nodes will be created in). If region is set to 'global' (default) then zone is mandatory, otherwise GCP is able to make use of Auto Zone Placement to determine this automatically for you. Note: This setting additionally determines and restricts which computing resources are available for use with other configs such as cluster_config.master_config.machine_type and cluster_config.worker_config.machine_type.
	// +optional
	Zone *string `json:"zone,omitempty" tf:"zone"`
}

type ClusterSpecClusterConfigGceClusterConfigCodec struct {
}

type ClusterSpecClusterConfigGceClusterConfigShieldedInstanceConfig struct {
	// Defines whether instances have integrity monitoring enabled.
	// +optional
	EnableIntegrityMonitoring *bool `json:"enableIntegrityMonitoring,omitempty" tf:"enable_integrity_monitoring"`
	// Defines whether instances have Secure Boot enabled.
	// +optional
	EnableSecureBoot *bool `json:"enableSecureBoot,omitempty" tf:"enable_secure_boot"`
	// Defines whether instances have the vTPM enabled.
	// +optional
	EnableVtpm *bool `json:"enableVtpm,omitempty" tf:"enable_vtpm"`
}

type ClusterSpecClusterConfigGceClusterConfigShieldedInstanceConfigCodec struct {
}

type ClusterSpecClusterConfigInitializationAction struct {
	// The script to be executed during initialization of the cluster. The script must be a GCS file with a gs:// prefix.
	Script *string `json:"script" tf:"script"`
	// The maximum duration (in seconds) which script is allowed to take to execute its action. GCP will default to a predetermined computed value if not set (currently 300).
	// +optional
	TimeoutSec *int64 `json:"timeoutSec,omitempty" tf:"timeout_sec"`
}

type ClusterSpecClusterConfigMasterConfig struct {
	// The Compute Engine accelerator (GPU) configuration for these instances. Can be specified multiple times.
	// +optional
	Accelerators []ClusterSpecClusterConfigMasterConfigAccelerators `json:"accelerators,omitempty" tf:"accelerators"`
	// Disk Config
	// +optional
	DiskConfig *ClusterSpecClusterConfigMasterConfigDiskConfig `json:"diskConfig,omitempty" tf:"disk_config"`
	// The URI for the image to use for this master/worker
	// +optional
	ImageURI *string `json:"imageURI,omitempty" tf:"image_uri"`
	// List of master/worker instance names which have been assigned to the cluster.
	// +optional
	InstanceNames []string `json:"instanceNames,omitempty" tf:"instance_names"`
	// The name of a Google Compute Engine machine type to create for the master/worker
	// +optional
	MachineType *string `json:"machineType,omitempty" tf:"machine_type"`
	// The name of a minimum generation of CPU family for the master/worker. If not specified, GCP will default to a predetermined computed value for each zone.
	// +optional
	MinCPUPlatform *string `json:"minCPUPlatform,omitempty" tf:"min_cpu_platform"`
	// Specifies the number of master/worker nodes to create. If not specified, GCP will default to a predetermined computed value.
	// +optional
	NumInstances *int64 `json:"numInstances,omitempty" tf:"num_instances"`
}

type ClusterSpecClusterConfigMasterConfigAccelerators struct {
	// The number of the accelerator cards of this type exposed to this instance. Often restricted to one of 1, 2, 4, or 8.
	AcceleratorCount *int64 `json:"acceleratorCount" tf:"accelerator_count"`
	// The short name of the accelerator type to expose to this instance. For example, nvidia-tesla-k80.
	AcceleratorType *string `json:"acceleratorType" tf:"accelerator_type"`
}

type ClusterSpecClusterConfigMasterConfigCodec struct {
}

type ClusterSpecClusterConfigMasterConfigDiskConfig struct {
	// Size of the primary disk attached to each node, specified in GB. The primary disk contains the boot volume and system libraries, and the smallest allowed disk size is 10GB. GCP will default to a predetermined computed value if not set (currently 500GB). Note: If SSDs are not attached, it also contains the HDFS data blocks and Hadoop working directories.
	// +optional
	BootDiskSizeGb *int64 `json:"bootDiskSizeGb,omitempty" tf:"boot_disk_size_gb"`
	// The disk type of the primary disk attached to each node. One of "pd-ssd" or "pd-standard". Defaults to "pd-standard".
	// +optional
	BootDiskType *string `json:"bootDiskType,omitempty" tf:"boot_disk_type"`
	// The amount of local SSD disks that will be attached to each master cluster node. Defaults to 0.
	// +optional
	NumLocalSsds *int64 `json:"numLocalSsds,omitempty" tf:"num_local_ssds"`
}

type ClusterSpecClusterConfigMasterConfigDiskConfigCodec struct {
}

type ClusterSpecClusterConfigPreemptibleWorkerConfig struct {
	// Disk Config
	// +optional
	DiskConfig *ClusterSpecClusterConfigPreemptibleWorkerConfigDiskConfig `json:"diskConfig,omitempty" tf:"disk_config"`
	// List of preemptible instance names which have been assigned to the cluster.
	// +optional
	InstanceNames []string `json:"instanceNames,omitempty" tf:"instance_names"`
	// Specifies the number of preemptible nodes to create. Defaults to 0.
	// +optional
	NumInstances *int64 `json:"numInstances,omitempty" tf:"num_instances"`
}

type ClusterSpecClusterConfigPreemptibleWorkerConfigCodec struct {
}

type ClusterSpecClusterConfigPreemptibleWorkerConfigDiskConfig struct {
	// Size of the primary disk attached to each preemptible worker node, specified in GB. The smallest allowed disk size is 10GB. GCP will default to a predetermined computed value if not set (currently 500GB). Note: If SSDs are not attached, it also contains the HDFS data blocks and Hadoop working directories.
	// +optional
	BootDiskSizeGb *int64 `json:"bootDiskSizeGb,omitempty" tf:"boot_disk_size_gb"`
	// The disk type of the primary disk attached to each preemptible worker node. One of "pd-ssd" or "pd-standard". Defaults to "pd-standard".
	// +optional
	BootDiskType *string `json:"bootDiskType,omitempty" tf:"boot_disk_type"`
	// The amount of local SSD disks that will be attached to each preemptible worker node. Defaults to 0.
	// +optional
	NumLocalSsds *int64 `json:"numLocalSsds,omitempty" tf:"num_local_ssds"`
}

type ClusterSpecClusterConfigPreemptibleWorkerConfigDiskConfigCodec struct {
}

type ClusterSpecClusterConfigSecurityConfig struct {
	// Kerberos related configuration
	KerberosConfig *ClusterSpecClusterConfigSecurityConfigKerberosConfig `json:"kerberosConfig" tf:"kerberos_config"`
}

type ClusterSpecClusterConfigSecurityConfigCodec struct {
}

type ClusterSpecClusterConfigSecurityConfigKerberosConfig struct {
	// The admin server (IP or hostname) for the remote trusted realm in a cross realm trust relationship.
	// +optional
	CrossRealmTrustAdminServer *string `json:"crossRealmTrustAdminServer,omitempty" tf:"cross_realm_trust_admin_server"`
	// The KDC (IP or hostname) for the remote trusted realm in a cross realm trust relationship.
	// +optional
	CrossRealmTrustKdc *string `json:"crossRealmTrustKdc,omitempty" tf:"cross_realm_trust_kdc"`
	// The remote realm the Dataproc on-cluster KDC will trust, should the user enable cross realm trust.
	// +optional
	CrossRealmTrustRealm *string `json:"crossRealmTrustRealm,omitempty" tf:"cross_realm_trust_realm"`
	// The Cloud Storage URI of a KMS encrypted file containing the shared password between the on-cluster
	// Kerberos realm and the remote trusted realm, in a cross realm trust relationship.
	// +optional
	CrossRealmTrustSharedPasswordURI *string `json:"crossRealmTrustSharedPasswordURI,omitempty" tf:"cross_realm_trust_shared_password_uri"`
	// Flag to indicate whether to Kerberize the cluster.
	// +optional
	EnableKerberos *bool `json:"enableKerberos,omitempty" tf:"enable_kerberos"`
	// The Cloud Storage URI of a KMS encrypted file containing the master key of the KDC database.
	// +optional
	KdcDbKeyURI *string `json:"kdcDbKeyURI,omitempty" tf:"kdc_db_key_uri"`
	// The Cloud Storage URI of a KMS encrypted file containing the password to the user provided key. For the self-signed certificate, this password is generated by Dataproc.
	// +optional
	KeyPasswordURI *string `json:"keyPasswordURI,omitempty" tf:"key_password_uri"`
	// The Cloud Storage URI of a KMS encrypted file containing
	// the password to the user provided keystore. For the self-signed certificate, this password is generated
	// by Dataproc
	// +optional
	KeystorePasswordURI *string `json:"keystorePasswordURI,omitempty" tf:"keystore_password_uri"`
	// The Cloud Storage URI of the keystore file used for SSL encryption. If not provided, Dataproc will provide a self-signed certificate.
	// +optional
	KeystoreURI *string `json:"keystoreURI,omitempty" tf:"keystore_uri"`
	// The uri of the KMS key used to encrypt various sensitive files.
	KmsKeyURI *string `json:"kmsKeyURI" tf:"kms_key_uri"`
	// The name of the on-cluster Kerberos realm. If not specified, the uppercased domain of hostnames will be the realm.
	// +optional
	Realm *string `json:"realm,omitempty" tf:"realm"`
	// The cloud Storage URI of a KMS encrypted file containing the root principal password.
	RootPrincipalPasswordURI *string `json:"rootPrincipalPasswordURI" tf:"root_principal_password_uri"`
	// The lifetime of the ticket granting ticket, in hours.
	// +optional
	TgtLifetimeHours *int64 `json:"tgtLifetimeHours,omitempty" tf:"tgt_lifetime_hours"`
	// The Cloud Storage URI of a KMS encrypted file containing the password to the user provided truststore. For the self-signed certificate, this password is generated by Dataproc.
	// +optional
	TruststorePasswordURI *string `json:"truststorePasswordURI,omitempty" tf:"truststore_password_uri"`
	// The Cloud Storage URI of the truststore file used for SSL encryption. If not provided, Dataproc will provide a self-signed certificate.
	// +optional
	TruststoreURI *string `json:"truststoreURI,omitempty" tf:"truststore_uri"`
}

type ClusterSpecClusterConfigSecurityConfigKerberosConfigCodec struct {
}

type ClusterSpecClusterConfigSoftwareConfig struct {
	// The Cloud Dataproc image version to use for the cluster - this controls the sets of software versions installed onto the nodes when you create clusters. If not specified, defaults to the latest version.
	// +optional
	ImageVersion *string `json:"imageVersion,omitempty" tf:"image_version"`
	// The set of optional components to activate on the cluster.
	// +optional
	OptionalComponents []string `json:"optionalComponents,omitempty" tf:"optional_components"`
	// A list of override and additional properties (key/value pairs) used to modify various aspects of the common configuration files used when creating a cluster.
	// +optional
	OverrideProperties *map[string]string `json:"overrideProperties,omitempty" tf:"override_properties"`
	// A list of the properties used to set the daemon config files. This will include any values supplied by the user via cluster_config.software_config.override_properties
	// +optional
	Properties map[string]string `json:"properties,omitempty" tf:"properties"`
}

type ClusterSpecClusterConfigSoftwareConfigCodec struct {
}

type ClusterSpecClusterConfigWorkerConfig struct {
	// The Compute Engine accelerator (GPU) configuration for these instances. Can be specified multiple times.
	// +optional
	Accelerators []ClusterSpecClusterConfigWorkerConfigAccelerators `json:"accelerators,omitempty" tf:"accelerators"`
	// Disk Config
	// +optional
	DiskConfig *ClusterSpecClusterConfigWorkerConfigDiskConfig `json:"diskConfig,omitempty" tf:"disk_config"`
	// The URI for the image to use for this master/worker
	// +optional
	ImageURI *string `json:"imageURI,omitempty" tf:"image_uri"`
	// List of master/worker instance names which have been assigned to the cluster.
	// +optional
	InstanceNames []string `json:"instanceNames,omitempty" tf:"instance_names"`
	// The name of a Google Compute Engine machine type to create for the master/worker
	// +optional
	MachineType *string `json:"machineType,omitempty" tf:"machine_type"`
	// The name of a minimum generation of CPU family for the master/worker. If not specified, GCP will default to a predetermined computed value for each zone.
	// +optional
	MinCPUPlatform *string `json:"minCPUPlatform,omitempty" tf:"min_cpu_platform"`
	// Specifies the number of master/worker nodes to create. If not specified, GCP will default to a predetermined computed value.
	// +optional
	NumInstances *int64 `json:"numInstances,omitempty" tf:"num_instances"`
}

type ClusterSpecClusterConfigWorkerConfigAccelerators struct {
	// The number of the accelerator cards of this type exposed to this instance. Often restricted to one of 1, 2, 4, or 8.
	AcceleratorCount *int64 `json:"acceleratorCount" tf:"accelerator_count"`
	// The short name of the accelerator type to expose to this instance. For example, nvidia-tesla-k80.
	AcceleratorType *string `json:"acceleratorType" tf:"accelerator_type"`
}

type ClusterSpecClusterConfigWorkerConfigCodec struct {
}

type ClusterSpecClusterConfigWorkerConfigDiskConfig struct {
	// Size of the primary disk attached to each node, specified in GB. The primary disk contains the boot volume and system libraries, and the smallest allowed disk size is 10GB. GCP will default to a predetermined computed value if not set (currently 500GB). Note: If SSDs are not attached, it also contains the HDFS data blocks and Hadoop working directories.
	// +optional
	BootDiskSizeGb *int64 `json:"bootDiskSizeGb,omitempty" tf:"boot_disk_size_gb"`
	// The disk type of the primary disk attached to each node. One of "pd-ssd" or "pd-standard". Defaults to "pd-standard".
	// +optional
	BootDiskType *string `json:"bootDiskType,omitempty" tf:"boot_disk_type"`
	// The amount of local SSD disks that will be attached to each master cluster node. Defaults to 0.
	// +optional
	NumLocalSsds *int64 `json:"numLocalSsds,omitempty" tf:"num_local_ssds"`
}

type ClusterSpecClusterConfigWorkerConfigDiskConfigCodec struct {
}

type ClusterSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// Allows you to configure various aspects of the cluster.
	// +optional
	ClusterConfig *ClusterSpecClusterConfig `json:"clusterConfig,omitempty" tf:"cluster_config"`
	// The timeout duration which allows graceful decomissioning when you change the number of worker nodes directly through a terraform apply
	// +optional
	GracefulDecommissionTimeout *string `json:"gracefulDecommissionTimeout,omitempty" tf:"graceful_decommission_timeout"`
	// The list of labels (key/value pairs) to be applied to instances in the cluster. GCP generates some itself including goog-dataproc-cluster-name which is the name of the cluster.
	// +optional
	Labels *map[string]string `json:"labels,omitempty" tf:"labels"`
	// The name of the cluster, unique within the project and zone.
	Name *string `json:"name" tf:"name"`
	// The ID of the project in which the cluster will exist. If it is not provided, the provider project is used.
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// The region in which the cluster and associated nodes will be created in. Defaults to global.
	// +optional
	Region *string `json:"region,omitempty" tf:"region"`
}

type ClusterStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

type Job struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              JobSpec   `json:"spec,omitempty"`
	Status            JobStatus `json:"status,omitempty"`
}

type JobIamBinding struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              JobIamBindingSpec   `json:"spec,omitempty"`
	Status            JobIamBindingStatus `json:"status,omitempty"`
}

type JobIamBindingList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of JobIamBinding CRD objects
	Items []JobIamBinding `json:"items,omitempty"`
}

type JobIamBindingSpec struct {
	State *JobIamBindingSpecResource `json:"state,omitempty" tf:"-"`

	Resource JobIamBindingSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

type JobIamBindingSpecCondition struct {
	// +optional
	Description *string `json:"description,omitempty" tf:"description"`
	Expression  *string `json:"expression" tf:"expression"`
	Title       *string `json:"title" tf:"title"`
}

type JobIamBindingSpecConditionCodec struct {
}

type JobIamBindingSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	Condition *JobIamBindingSpecCondition `json:"condition,omitempty" tf:"condition"`
	// +optional
	Etag    *string  `json:"etag,omitempty" tf:"etag"`
	JobID   *string  `json:"jobID" tf:"job_id"`
	Members []string `json:"members" tf:"members"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// +optional
	Region *string `json:"region,omitempty" tf:"region"`
	Role   *string `json:"role" tf:"role"`
}

type JobIamBindingStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

type JobIamMember struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              JobIamMemberSpec   `json:"spec,omitempty"`
	Status            JobIamMemberStatus `json:"status,omitempty"`
}

type JobIamMemberList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of JobIamMember CRD objects
	Items []JobIamMember `json:"items,omitempty"`
}

type JobIamMemberSpec struct {
	State *JobIamMemberSpecResource `json:"state,omitempty" tf:"-"`

	Resource JobIamMemberSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

type JobIamMemberSpecCondition struct {
	// +optional
	Description *string `json:"description,omitempty" tf:"description"`
	Expression  *string `json:"expression" tf:"expression"`
	Title       *string `json:"title" tf:"title"`
}

type JobIamMemberSpecConditionCodec struct {
}

type JobIamMemberSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	Condition *JobIamMemberSpecCondition `json:"condition,omitempty" tf:"condition"`
	// +optional
	Etag   *string `json:"etag,omitempty" tf:"etag"`
	JobID  *string `json:"jobID" tf:"job_id"`
	Member *string `json:"member" tf:"member"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// +optional
	Region *string `json:"region,omitempty" tf:"region"`
	Role   *string `json:"role" tf:"role"`
}

type JobIamMemberStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

type JobIamPolicy struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              JobIamPolicySpec   `json:"spec,omitempty"`
	Status            JobIamPolicyStatus `json:"status,omitempty"`
}

type JobIamPolicyList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of JobIamPolicy CRD objects
	Items []JobIamPolicy `json:"items,omitempty"`
}

type JobIamPolicySpec struct {
	State *JobIamPolicySpecResource `json:"state,omitempty" tf:"-"`

	Resource JobIamPolicySpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

type JobIamPolicySpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	Etag       *string `json:"etag,omitempty" tf:"etag"`
	JobID      *string `json:"jobID" tf:"job_id"`
	PolicyData *string `json:"policyData" tf:"policy_data"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// +optional
	Region *string `json:"region,omitempty" tf:"region"`
}

type JobIamPolicyStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

type JobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of Job CRD objects
	Items []Job `json:"items,omitempty"`
}

type JobSpec struct {
	State *JobSpecResource `json:"state,omitempty" tf:"-"`

	Resource JobSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

type JobSpecHadoopConfig struct {
	// HCFS URIs of archives to be extracted in the working directory of .jar, .tar, .tar.gz, .tgz, and .zip.
	// +optional
	ArchiveUris []string `json:"archiveUris,omitempty" tf:"archive_uris"`
	// The arguments to pass to the driver.
	// +optional
	Args []string `json:"args,omitempty" tf:"args"`
	// HCFS URIs of files to be copied to the working directory of Spark drivers and distributed tasks. Useful for naively parallel tasks.
	// +optional
	FileUris []string `json:"fileUris,omitempty" tf:"file_uris"`
	// HCFS URIs of jar files to add to the CLASSPATHs of the Spark driver and tasks.
	// +optional
	JarFileUris []string `json:"jarFileUris,omitempty" tf:"jar_file_uris"`
	// The runtime logging config of the job
	// +optional
	LoggingConfig *JobSpecHadoopConfigLoggingConfig `json:"loggingConfig,omitempty" tf:"logging_config"`
	// The class containing the main method of the driver. Must be in a provided jar or jar that is already on the classpath. Conflicts with main_jar_file_uri
	// +optional
	MainClass *string `json:"mainClass,omitempty" tf:"main_class"`
	// The HCFS URI of jar file containing the driver jar. Conflicts with main_class
	// +optional
	MainJarFileURI *string `json:"mainJarFileURI,omitempty" tf:"main_jar_file_uri"`
	// A mapping of property names to values, used to configure Spark. Properties that conflict with values set by the Cloud Dataproc API may be overwritten. Can include properties set in /etc/spark/conf/spark-defaults.conf and classes in user code.
	// +optional
	Properties *map[string]string `json:"properties,omitempty" tf:"properties"`
}

type JobSpecHadoopConfigCodec struct {
}

type JobSpecHadoopConfigLoggingConfig struct {
	// Optional. The per-package log levels for the driver. This may include 'root' package name to configure rootLogger. Examples: 'com.google = FATAL', 'root = INFO', 'org.apache = DEBUG'.
	DriverLogLevels *map[string]string `json:"driverLogLevels" tf:"driver_log_levels"`
}

type JobSpecHadoopConfigLoggingConfigCodec struct {
}

type JobSpecHiveConfig struct {
	// Whether to continue executing queries if a query fails. The default value is false. Setting to true can be useful when executing independent parallel queries. Defaults to false.
	// +optional
	ContinueOnFailure *bool `json:"continueOnFailure,omitempty" tf:"continue_on_failure"`
	// HCFS URIs of jar files to add to the CLASSPATH of the Hive server and Hadoop MapReduce (MR) tasks. Can contain Hive SerDes and UDFs.
	// +optional
	JarFileUris []string `json:"jarFileUris,omitempty" tf:"jar_file_uris"`
	// A mapping of property names and values, used to configure Hive. Properties that conflict with values set by the Cloud Dataproc API may be overwritten. Can include properties set in /etc/hadoop/conf/*-site.xml, /etc/hive/conf/hive-site.xml, and classes in user code.
	// +optional
	Properties *map[string]string `json:"properties,omitempty" tf:"properties"`
	// HCFS URI of file containing Hive script to execute as the job. Conflicts with query_list
	// +optional
	QueryFileURI *string `json:"queryFileURI,omitempty" tf:"query_file_uri"`
	// The list of Hive queries or statements to execute as part of the job. Conflicts with query_file_uri
	// +optional
	QueryList []string `json:"queryList,omitempty" tf:"query_list"`
	// Mapping of query variable names to values (equivalent to the Hive command: SET name="value";).
	// +optional
	ScriptVariables *map[string]string `json:"scriptVariables,omitempty" tf:"script_variables"`
}

type JobSpecHiveConfigCodec struct {
}

type JobSpecPigConfig struct {
	// Whether to continue executing queries if a query fails. The default value is false. Setting to true can be useful when executing independent parallel queries. Defaults to false.
	// +optional
	ContinueOnFailure *bool `json:"continueOnFailure,omitempty" tf:"continue_on_failure"`
	// HCFS URIs of jar files to add to the CLASSPATH of the Pig Client and Hadoop MapReduce (MR) tasks. Can contain Pig UDFs.
	// +optional
	JarFileUris []string `json:"jarFileUris,omitempty" tf:"jar_file_uris"`
	// The runtime logging config of the job
	// +optional
	LoggingConfig *JobSpecPigConfigLoggingConfig `json:"loggingConfig,omitempty" tf:"logging_config"`
	// A mapping of property names to values, used to configure Pig. Properties that conflict with values set by the Cloud Dataproc API may be overwritten. Can include properties set in /etc/hadoop/conf/*-site.xml, /etc/pig/conf/pig.properties, and classes in user code.
	// +optional
	Properties *map[string]string `json:"properties,omitempty" tf:"properties"`
	// HCFS URI of file containing Hive script to execute as the job. Conflicts with query_list
	// +optional
	QueryFileURI *string `json:"queryFileURI,omitempty" tf:"query_file_uri"`
	// The list of Hive queries or statements to execute as part of the job. Conflicts with query_file_uri
	// +optional
	QueryList []string `json:"queryList,omitempty" tf:"query_list"`
	// Mapping of query variable names to values (equivalent to the Pig command: name=[value]).
	// +optional
	ScriptVariables *map[string]string `json:"scriptVariables,omitempty" tf:"script_variables"`
}

type JobSpecPigConfigCodec struct {
}

type JobSpecPigConfigLoggingConfig struct {
	// Optional. The per-package log levels for the driver. This may include 'root' package name to configure rootLogger. Examples: 'com.google = FATAL', 'root = INFO', 'org.apache = DEBUG'.
	DriverLogLevels *map[string]string `json:"driverLogLevels" tf:"driver_log_levels"`
}

type JobSpecPigConfigLoggingConfigCodec struct {
}

type JobSpecPlacement struct {
	// The name of the cluster where the job will be submitted
	ClusterName *string `json:"clusterName" tf:"cluster_name"`
	// Output-only. A cluster UUID generated by the Cloud Dataproc service when the job is submitted
	// +optional
	ClusterUUID *string `json:"clusterUUID,omitempty" tf:"cluster_uuid"`
}

type JobSpecPlacementCodec struct {
}

type JobSpecPysparkConfig struct {
	// Optional. HCFS URIs of archives to be extracted in the working directory of .jar, .tar, .tar.gz, .tgz, and .zip
	// +optional
	ArchiveUris []string `json:"archiveUris,omitempty" tf:"archive_uris"`
	// Optional. The arguments to pass to the driver. Do not include arguments, such as --conf, that can be set as job properties, since a collision may occur that causes an incorrect job submission
	// +optional
	Args []string `json:"args,omitempty" tf:"args"`
	// Optional. HCFS URIs of files to be copied to the working directory of Python drivers and distributed tasks. Useful for naively parallel tasks
	// +optional
	FileUris []string `json:"fileUris,omitempty" tf:"file_uris"`
	// Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Python driver and tasks
	// +optional
	JarFileUris []string `json:"jarFileUris,omitempty" tf:"jar_file_uris"`
	// The runtime logging config of the job
	// +optional
	LoggingConfig *JobSpecPysparkConfigLoggingConfig `json:"loggingConfig,omitempty" tf:"logging_config"`
	// Required. The HCFS URI of the main Python file to use as the driver. Must be a .py file
	MainPythonFileURI *string `json:"mainPythonFileURI" tf:"main_python_file_uri"`
	// Optional. A mapping of property names to values, used to configure PySpark. Properties that conflict with values set by the Cloud Dataproc API may be overwritten. Can include properties set in /etc/spark/conf/spark-defaults.conf and classes in user code
	// +optional
	Properties *map[string]string `json:"properties,omitempty" tf:"properties"`
	// Optional. HCFS file URIs of Python files to pass to the PySpark framework. Supported file types: .py, .egg, and .zip
	// +optional
	PythonFileUris []string `json:"pythonFileUris,omitempty" tf:"python_file_uris"`
}

type JobSpecPysparkConfigCodec struct {
}

type JobSpecPysparkConfigLoggingConfig struct {
	// Optional. The per-package log levels for the driver. This may include 'root' package name to configure rootLogger. Examples: 'com.google = FATAL', 'root = INFO', 'org.apache = DEBUG'.
	DriverLogLevels *map[string]string `json:"driverLogLevels" tf:"driver_log_levels"`
}

type JobSpecPysparkConfigLoggingConfigCodec struct {
}

type JobSpecReference struct {
	// The job ID, which must be unique within the project. The job ID is generated by the server upon job submission or provided by the user as a means to perform retries without creating duplicate jobs
	// +optional
	JobID *string `json:"jobID,omitempty" tf:"job_id"`
}

type JobSpecReferenceCodec struct {
}

type JobSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// Output-only. If present, the location of miscellaneous control files which may be used as part of job setup and handling. If not present, control files may be placed in the same location as driver_output_uri.
	// +optional
	DriverControlsFilesURI *string `json:"driverControlsFilesURI,omitempty" tf:"driver_controls_files_uri"`
	// Output-only. A URI pointing to the location of the stdout of the job's driver program
	// +optional
	DriverOutputResourceURI *string `json:"driverOutputResourceURI,omitempty" tf:"driver_output_resource_uri"`
	// By default, you can only delete inactive jobs within Dataproc. Setting this to true, and calling destroy, will ensure that the job is first cancelled before issuing the delete.
	// +optional
	ForceDelete *bool `json:"forceDelete,omitempty" tf:"force_delete"`
	// The config of Hadoop job
	// +optional
	HadoopConfig *JobSpecHadoopConfig `json:"hadoopConfig,omitempty" tf:"hadoop_config"`
	// The config of hive job
	// +optional
	HiveConfig *JobSpecHiveConfig `json:"hiveConfig,omitempty" tf:"hive_config"`
	// Optional. The labels to associate with this job.
	// +optional
	Labels *map[string]string `json:"labels,omitempty" tf:"labels"`
	// The config of pag job.
	// +optional
	PigConfig *JobSpecPigConfig `json:"pigConfig,omitempty" tf:"pig_config"`
	// The config of job placement.
	Placement *JobSpecPlacement `json:"placement" tf:"placement"`
	// The project in which the cluster can be found and jobs subsequently run against. If it is not provided, the provider project is used.
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// The config of pySpark job.
	// +optional
	PysparkConfig *JobSpecPysparkConfig `json:"pysparkConfig,omitempty" tf:"pyspark_config"`
	// The reference of the job
	// +optional
	Reference *JobSpecReference `json:"reference,omitempty" tf:"reference"`
	// The Cloud Dataproc region. This essentially determines which clusters are available for this job to be submitted to. If not specified, defaults to global.
	// +optional
	Region *string `json:"region,omitempty" tf:"region"`
	// Optional. Job scheduling configuration.
	// +optional
	Scheduling *JobSpecScheduling `json:"scheduling,omitempty" tf:"scheduling"`
	// The config of the Spark job.
	// +optional
	SparkConfig *JobSpecSparkConfig `json:"sparkConfig,omitempty" tf:"spark_config"`
	// The config of SparkSql job
	// +optional
	SparksqlConfig *JobSpecSparksqlConfig `json:"sparksqlConfig,omitempty" tf:"sparksql_config"`
	// The status of the job.
	// +optional
	Status []JobSpecStatus `json:"status,omitempty" tf:"status"`
}

type JobSpecScheduling struct {
	// Maximum number of times per hour a driver may be restarted as a result of driver exiting with non-zero code before job is reported failed.
	MaxFailuresPerHour *int64 `json:"maxFailuresPerHour" tf:"max_failures_per_hour"`
	// Maximum number of times in total a driver may be restarted as a result of driver exiting with non-zero code before job is reported failed.
	MaxFailuresTotal *int64 `json:"maxFailuresTotal" tf:"max_failures_total"`
}

type JobSpecSchedulingCodec struct {
}

type JobSpecSparkConfig struct {
	// HCFS URIs of archives to be extracted in the working directory of .jar, .tar, .tar.gz, .tgz, and .zip.
	// +optional
	ArchiveUris []string `json:"archiveUris,omitempty" tf:"archive_uris"`
	// The arguments to pass to the driver.
	// +optional
	Args []string `json:"args,omitempty" tf:"args"`
	// HCFS URIs of files to be copied to the working directory of Spark drivers and distributed tasks. Useful for naively parallel tasks.
	// +optional
	FileUris []string `json:"fileUris,omitempty" tf:"file_uris"`
	// HCFS URIs of jar files to add to the CLASSPATHs of the Spark driver and tasks.
	// +optional
	JarFileUris []string `json:"jarFileUris,omitempty" tf:"jar_file_uris"`
	// The runtime logging config of the job
	// +optional
	LoggingConfig *JobSpecSparkConfigLoggingConfig `json:"loggingConfig,omitempty" tf:"logging_config"`
	// The class containing the main method of the driver. Must be in a provided jar or jar that is already on the classpath. Conflicts with main_jar_file_uri
	// +optional
	MainClass *string `json:"mainClass,omitempty" tf:"main_class"`
	// The HCFS URI of jar file containing the driver jar. Conflicts with main_class
	// +optional
	MainJarFileURI *string `json:"mainJarFileURI,omitempty" tf:"main_jar_file_uri"`
	// A mapping of property names to values, used to configure Spark. Properties that conflict with values set by the Cloud Dataproc API may be overwritten. Can include properties set in /etc/spark/conf/spark-defaults.conf and classes in user code.
	// +optional
	Properties *map[string]string `json:"properties,omitempty" tf:"properties"`
}