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, FlinkResourceContextFactory flinkResourceContextFactory, FlinkConfigManager configManager)
-
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(FlinkConfigManager configManager, 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.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. isResourceReadyToBeObserved(FlinkResourceContext<FlinkSessionJob> ctx)
protected void
FlinkSessionJobObserver. observeInternal(FlinkResourceContext<FlinkSessionJob> ctx)
protected void
FlinkSessionJobObserver. updateStatusToDeployedIfAlreadyUpgraded(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(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, EventRecorder eventRecorder, StatusRecorder<FlinkSessionJob,FlinkSessionJobStatus> statusRecorder)
-
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.
-