Uses of Class
org.apache.flink.kubernetes.operator.api.FlinkSessionJob
-
-
Uses of FlinkSessionJob in org.apache.flink.kubernetes.operator.api.listener
Method parameters in org.apache.flink.kubernetes.operator.api.listener with type arguments of type FlinkSessionJob Modifier and Type Method Description void
FlinkResourceListener. onSessionJobEvent(FlinkResourceListener.ResourceEventContext<FlinkSessionJob> ctx)
void
FlinkResourceListener. onSessionJobStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkSessionJob,FlinkSessionJobStatus> ctx)
-
Uses of FlinkSessionJob in org.apache.flink.kubernetes.operator.controller
Methods in org.apache.flink.kubernetes.operator.controller that return types with arguments of type FlinkSessionJob Modifier and Type Method Description io.javaoperatorsdk.operator.api.reconciler.UpdateControl<FlinkSessionJob>
FlinkSessionJobController. reconcile(FlinkSessionJob flinkSessionJob, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<FlinkSessionJob>
FlinkSessionJobController. updateErrorStatus(FlinkSessionJob sessionJob, io.javaoperatorsdk.operator.api.reconciler.Context<FlinkSessionJob> context, java.lang.Exception e)
Methods in org.apache.flink.kubernetes.operator.controller with parameters of type FlinkSessionJob Modifier and Type Method Description io.javaoperatorsdk.operator.api.reconciler.DeleteControl
FlinkSessionJobController. cleanup(FlinkSessionJob sessionJob, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
io.javaoperatorsdk.operator.api.reconciler.UpdateControl<FlinkSessionJob>
FlinkSessionJobController. reconcile(FlinkSessionJob flinkSessionJob, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<FlinkSessionJob>
FlinkSessionJobController. updateErrorStatus(FlinkSessionJob sessionJob, io.javaoperatorsdk.operator.api.reconciler.Context<FlinkSessionJob> context, java.lang.Exception e)
Method parameters in org.apache.flink.kubernetes.operator.controller with type arguments of type FlinkSessionJob Modifier and Type Method Description java.util.Map<java.lang.String,io.javaoperatorsdk.operator.processing.event.source.EventSource>
FlinkSessionJobController. prepareEventSources(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkSessionJob> context)
io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<FlinkSessionJob>
FlinkSessionJobController. updateErrorStatus(FlinkSessionJob sessionJob, io.javaoperatorsdk.operator.api.reconciler.Context<FlinkSessionJob> context, java.lang.Exception e)
Constructors in org.apache.flink.kubernetes.operator.controller with parameters of type FlinkSessionJob Constructor Description FlinkSessionJobContext(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> josdkContext, KubernetesResourceMetricGroup resourceMetricGroup, FlinkConfigManager configManager, java.util.function.Function<FlinkResourceContext<?>,FlinkService> flinkServiceFactory)
-
Uses of FlinkSessionJob in org.apache.flink.kubernetes.operator.metrics
Methods in org.apache.flink.kubernetes.operator.metrics that return types with arguments of type FlinkSessionJob Modifier and Type Method Description static MetricManager<FlinkSessionJob>
MetricManager. createFlinkSessionJobMetricManager(org.apache.flink.configuration.Configuration conf, KubernetesOperatorMetricGroup metricGroup)
Methods in org.apache.flink.kubernetes.operator.metrics with parameters of type FlinkSessionJob Modifier and Type Method Description void
FlinkSessionJobMetrics. onRemove(FlinkSessionJob sessionJob)
void
FlinkSessionJobMetrics. onUpdate(FlinkSessionJob sessionJob)
-
Uses of FlinkSessionJob in org.apache.flink.kubernetes.operator.mutator
Methods in org.apache.flink.kubernetes.operator.mutator that return FlinkSessionJob Modifier and Type Method Description FlinkSessionJob
DefaultFlinkMutator. mutateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<FlinkDeployment> session)
FlinkSessionJob
FlinkResourceMutator. mutateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<FlinkDeployment> session)
Mutate session job and return the mutated Object.Methods in org.apache.flink.kubernetes.operator.mutator with parameters of type FlinkSessionJob Modifier and Type Method Description FlinkSessionJob
DefaultFlinkMutator. mutateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<FlinkDeployment> session)
FlinkSessionJob
FlinkResourceMutator. mutateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<FlinkDeployment> session)
Mutate session job and return the mutated Object. -
Uses of FlinkSessionJob in org.apache.flink.kubernetes.operator.observer.sessionjob
Method parameters in org.apache.flink.kubernetes.operator.observer.sessionjob with type arguments of type FlinkSessionJob Modifier and Type Method Description protected boolean
FlinkSessionJobObserver. checkIfAlreadyUpgraded(FlinkResourceContext<FlinkSessionJob> ctx)
protected boolean
FlinkSessionJobObserver. isResourceReadyToBeObserved(FlinkResourceContext<FlinkSessionJob> ctx)
protected void
FlinkSessionJobObserver. observeInternal(FlinkResourceContext<FlinkSessionJob> ctx)
-
Uses of FlinkSessionJob in org.apache.flink.kubernetes.operator.reconciler.sessionjob
Method parameters in org.apache.flink.kubernetes.operator.reconciler.sessionjob with type arguments of type FlinkSessionJob Modifier and Type Method Description protected void
SessionJobReconciler. cancelJob(FlinkResourceContext<FlinkSessionJob> ctx, UpgradeMode upgradeMode)
protected void
SessionJobReconciler. cleanupAfterFailedJob(FlinkResourceContext<FlinkSessionJob> ctx)
io.javaoperatorsdk.operator.api.reconciler.DeleteControl
SessionJobReconciler. cleanupInternal(FlinkResourceContext<FlinkSessionJob> ctx)
void
SessionJobReconciler. deploy(FlinkResourceContext<FlinkSessionJob> ctx, FlinkSessionJobSpec sessionJobSpec, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
boolean
SessionJobReconciler. readyToReconcile(FlinkResourceContext<FlinkSessionJob> ctx)
Constructor parameters in org.apache.flink.kubernetes.operator.reconciler.sessionjob with type arguments of type FlinkSessionJob Constructor Description SessionJobReconciler(EventRecorder eventRecorder, StatusRecorder<FlinkSessionJob,FlinkSessionJobStatus> statusRecorder, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
-
Uses of FlinkSessionJob in org.apache.flink.kubernetes.operator.service
Methods in org.apache.flink.kubernetes.operator.service with parameters of type FlinkSessionJob Modifier and Type Method Description void
AbstractFlinkService. cancelSessionJob(FlinkSessionJob sessionJob, UpgradeMode upgradeMode, org.apache.flink.configuration.Configuration conf)
void
FlinkService. cancelSessionJob(FlinkSessionJob sessionJob, UpgradeMode upgradeMode, org.apache.flink.configuration.Configuration conf)
-
Uses of FlinkSessionJob in org.apache.flink.kubernetes.operator.utils
Methods in org.apache.flink.kubernetes.operator.utils that return types with arguments of type FlinkSessionJob Modifier and Type Method Description static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<FlinkDeployment,FlinkSessionJob>
EventSourceUtils. getFlinkDeploymentInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkSessionJob> context)
static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<FlinkSessionJob,FlinkDeployment>
EventSourceUtils. getSessionJobInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)
Method parameters in org.apache.flink.kubernetes.operator.utils with type arguments of type FlinkSessionJob Modifier and Type Method Description static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<FlinkDeployment,FlinkSessionJob>
EventSourceUtils. getFlinkDeploymentInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkSessionJob> context)
-
Uses of FlinkSessionJob in org.apache.flink.kubernetes.operator.validation
Methods in org.apache.flink.kubernetes.operator.validation with parameters of type FlinkSessionJob Modifier and Type Method Description java.util.Optional<java.lang.String>
DefaultValidator. validateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<FlinkDeployment> sessionOpt)
java.util.Optional<java.lang.String>
FlinkResourceValidator. validateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<FlinkDeployment> session)
Validate and return optional error.
-