# Functions
No description provided by the author
# 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.
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.
control annotation key.
control name.
User requested control.
User requested control.
control state.
User requested control.
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.
Control state.
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.
JobManagerServiceStatus defines the observed state of FlinkCluster.
JobManagerSpec defines properties of JobManager.
JobSpec defines properties of a Flink job.
JobStatus defines the status of a job.
NativeJobClusterJobSpec defines properties of a Native Flink job cluster.
NativeSessionClusterJobSpec defines properties of a Native Flink session cluster.
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.