# Constants
AccessScope defines the access scope of JobManager service.
AccessScope defines the access scope of JobManager service.
AccessScope defines the access scope of JobManager service.
CleanupActionDeleteCluster - delete the entire cluster.
CleanupActionDeleteTaskManager - delete task manager, keep job manager.
CleanupActionKeepCluster - keep the entire cluster.
ClusterState defines states for a cluster.
ClusterState defines states for a cluster.
ClusterState defines states for a cluster.
ClusterState defines states for a cluster.
ClusterState defines states for a cluster.
ClusterState defines states for a cluster.
ComponentState defines states for a cluster component.
ComponentState defines states for a cluster component.
ComponentState defines states for a cluster component.
JobRestartPolicyFromSavepointOnFailure - restart the job from the latest savepoint if available, otherwise do not restart.
JobRestartPolicyNever - never restarts a failed job.
JobState defines states for a Flink job.
JobState defines states for a Flink job.
JobState defines states for a Flink job.
JobState defines states for a Flink job.
JobState defines states for a Flink job.
JobState defines states for a Flink job.
# Variables
AddToScheme adds the types in this group-version to the given scheme.
GroupVersion is group version used to register these objects.
SchemeBuilder is used to add go types to the GroupVersionKind scheme.
# Structs
CleanupPolicy defines the action to take after job finishes.
FlinkCluster is the Schema for the flinkclusters API +kubebuilder:subresource:status.
FlinkClusterComponentsStatus defines the observed status of the components of a FlinkCluster.
FlinkClusterComponentState defines the observed state of a component of a FlinkCluster.
FlinkClusterList contains a list of FlinkCluster.
FlinkClusterSpec defines the desired state of FlinkCluster.
FlinkClusterStatus defines the observed state of FlinkCluster.
GCPConfig defines configs for GCP.
GCPServiceAccount defines the config about GCP service account.
HadoopConfig defines configs for Hadoop.
ImageSpec defines Flink image of JobManager and TaskManager containers.
JobManagerIngressSpec defines ingress of JobManager.
JobManagerIngressStatus defines the status of a JobManager ingress.
JobManagerPorts defines ports of JobManager.
JobManagerSpec defines properties of JobManager.
JobSpec defines properties of a Flink job.
JobStatus defines the status of a job.
TaskManagerPorts defines ports of TaskManager.
TaskManagerSpec defines properties of TaskManager.
Validator validates CUD requests for the CR.
# Type aliases
CleanupAction defines the action to take after job finishes.
JobRestartPolicy defines the restart policy when a job fails.