Uses of Class
org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobStatus
-
-
Uses of FlinkSessionJobStatus in org.apache.flink.kubernetes.operator.api
Methods in org.apache.flink.kubernetes.operator.api that return FlinkSessionJobStatus Modifier and Type Method Description protected FlinkSessionJobStatus
FlinkSessionJob. initStatus()
-
Uses of FlinkSessionJobStatus in org.apache.flink.kubernetes.operator.api.listener
Method parameters in org.apache.flink.kubernetes.operator.api.listener with type arguments of type FlinkSessionJobStatus Modifier and Type Method Description void
FlinkResourceListener. onSessionJobStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkSessionJob,FlinkSessionJobStatus> ctx)
-
Uses of FlinkSessionJobStatus in org.apache.flink.kubernetes.operator.controller
Constructor parameters in org.apache.flink.kubernetes.operator.controller with type arguments of type FlinkSessionJobStatus Constructor Description FlinkSessionJobController(java.util.Set<FlinkResourceValidator> validators, FlinkResourceContextFactory ctxFactory, Reconciler<FlinkSessionJob> reconciler, Observer<FlinkSessionJob> observer, StatusRecorder<FlinkSessionJob,FlinkSessionJobStatus> statusRecorder, EventRecorder eventRecorder, CanaryResourceManager<FlinkSessionJob> canaryResourceManager)
-
Uses of FlinkSessionJobStatus in org.apache.flink.kubernetes.operator.reconciler.sessionjob
Constructor parameters in org.apache.flink.kubernetes.operator.reconciler.sessionjob with type arguments of type FlinkSessionJobStatus Constructor Description SessionJobReconciler(EventRecorder eventRecorder, StatusRecorder<FlinkSessionJob,FlinkSessionJobStatus> statusRecorder, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
-