Package org.apache.flink.kubernetes.operator.controller

Class FlinkSessionJobController

java.lang.Object

org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController

All Implemented Interfaces:

io.javaoperatorsdk.operator.api.reconciler.Cleaner<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>, io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>, io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>, io.javaoperatorsdk.operator.api.reconciler.Reconciler<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>

public class FlinkSessionJobController
extends java.lang.Object
implements io.javaoperatorsdk.operator.api.reconciler.Reconciler<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>, io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>, io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>, io.javaoperatorsdk.operator.api.reconciler.Cleaner<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>

Controller that runs the main reconcile loop for FlinkSessionJob.

Constructor Summary

Constructors

Constructor

Description

FlinkSessionJobController(FlinkConfigManager configManager, java.util.Set<FlinkResourceValidator> validators, Reconciler<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> reconciler, Observer<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> observer, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobStatus> statusRecorder, EventRecorder eventRecorder)

Method Summary

Modifier and Type	Method	Description
io.javaoperatorsdk.operator.api.reconciler.DeleteControl	cleanup(org.apache.flink.kubernetes.operator.api.FlinkSessionJob sessionJob, io.javaoperatorsdk.operator.api.reconciler.Context context)
java.util.Map<java.lang.String,io.javaoperatorsdk.operator.processing.event.source.EventSource>	prepareEventSources(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> context)
io.javaoperatorsdk.operator.api.reconciler.UpdateControl<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>	reconcile(org.apache.flink.kubernetes.operator.api.FlinkSessionJob flinkSessionJob, io.javaoperatorsdk.operator.api.reconciler.Context context)
io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>	updateErrorStatus(org.apache.flink.kubernetes.operator.api.FlinkSessionJob sessionJob, io.javaoperatorsdk.operator.api.reconciler.Context<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> context, java.lang.Exception e)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlinkSessionJobController

public FlinkSessionJobController(FlinkConfigManager configManager,
                                 java.util.Set<FlinkResourceValidator> validators,
                                 Reconciler<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> reconciler,
                                 Observer<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> observer,
                                 StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobStatus> statusRecorder,
                                 EventRecorder eventRecorder)

Method Detail

reconcile

public io.javaoperatorsdk.operator.api.reconciler.UpdateControl<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> reconcile(org.apache.flink.kubernetes.operator.api.FlinkSessionJob flinkSessionJob,
                                                                                                                                    io.javaoperatorsdk.operator.api.reconciler.Context context)

Specified by:

reconcile in interface io.javaoperatorsdk.operator.api.reconciler.Reconciler<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>

cleanup

public io.javaoperatorsdk.operator.api.reconciler.DeleteControl cleanup(org.apache.flink.kubernetes.operator.api.FlinkSessionJob sessionJob,
                                                                        io.javaoperatorsdk.operator.api.reconciler.Context context)

Specified by:

cleanup in interface io.javaoperatorsdk.operator.api.reconciler.Cleaner<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>

updateErrorStatus

public io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> updateErrorStatus(org.apache.flink.kubernetes.operator.api.FlinkSessionJob sessionJob,
                                                                                                                                                       io.javaoperatorsdk.operator.api.reconciler.Context<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> context,
                                                                                                                                                       java.lang.Exception e)

Specified by:

updateErrorStatus in interface io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>

prepareEventSources

public java.util.Map<java.lang.String,io.javaoperatorsdk.operator.processing.event.source.EventSource> prepareEventSources(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> context)

Specified by:

prepareEventSources in interface io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>