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 context)
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 context)
io.javaoperatorsdk.operator.api.reconciler.UpdateControl<FlinkSessionJob>
FlinkSessionJobController. reconcile(FlinkSessionJob flinkSessionJob, io.javaoperatorsdk.operator.api.reconciler.Context context)
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)
-
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
Methods in org.apache.flink.kubernetes.operator.observer.sessionjob with parameters of type FlinkSessionJob Modifier and Type Method Description protected FlinkSessionJobObserverContext
FlinkSessionJobObserver. getObserverContext(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
protected boolean
FlinkSessionJobObserver. isResourceReadyToBeObserved(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkSessionJobObserverContext observerContext)
protected void
FlinkSessionJobObserver. observeInternal(FlinkSessionJob flinkSessionJob, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, FlinkSessionJobObserverContext observerContext)
protected void
FlinkSessionJobObserver. updateStatusToDeployedIfAlreadyUpgraded(FlinkSessionJob flinkSessionJob, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, FlinkSessionJobObserverContext observerContext)
Constructors in org.apache.flink.kubernetes.operator.observer.sessionjob with parameters of type FlinkSessionJob Constructor Description FlinkSessionJobObserverContext(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> resourceContext, FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager)
-
Uses of FlinkSessionJob in org.apache.flink.kubernetes.operator.reconciler.sessionjob
Methods in org.apache.flink.kubernetes.operator.reconciler.sessionjob with parameters of type FlinkSessionJob Modifier and Type Method Description protected void
SessionJobReconciler. cancelJob(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, UpgradeMode upgradeMode, org.apache.flink.configuration.Configuration observeConfig)
protected void
SessionJobReconciler. cleanupAfterFailedJob(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration observeConfig)
io.javaoperatorsdk.operator.api.reconciler.DeleteControl
SessionJobReconciler. cleanupInternal(FlinkSessionJob sessionJob, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
protected void
SessionJobReconciler. deploy(FlinkSessionJob cr, FlinkSessionJobSpec sessionJobSpec, FlinkSessionJobStatus status, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
protected FlinkService
SessionJobReconciler. getFlinkService(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
protected org.apache.flink.configuration.Configuration
SessionJobReconciler. getObserveConfig(FlinkSessionJob sessionJob, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
boolean
SessionJobReconciler. readyToReconcile(FlinkSessionJob flinkSessionJob, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, org.apache.flink.configuration.Configuration deployConfig)
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, FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, 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.
-