Package org.apache.flink.kubernetes.operator.api.listener

Interface FlinkResourceListener

All Superinterfaces:

org.apache.flink.core.plugin.Plugin

public interface FlinkResourceListener
extends org.apache.flink.core.plugin.Plugin

Listener interface for Flink resource related events and status changes.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	FlinkResourceListener.FlinkResourceContext<R extends AbstractFlinkResource<?,?>>	Base for Flink resource Event and StatusUpdate contexts.
static interface	FlinkResourceListener.FlinkStateSnapshotEventContext	Context for FlinkStateSnapshot Event listener methods.
static interface	FlinkResourceListener.FlinkStateSnapshotResourceContext	Base for FlinkStateSnapshot Event and StatusUpdate contexts.
static interface	FlinkResourceListener.FlinkStateSnapshotStatusUpdateContext	Context for FlinkStateSnapshot Status listener methods.
static interface	FlinkResourceListener.ResourceContext	Base for Resource Event and StatusUpdate contexts.
static interface	FlinkResourceListener.ResourceEventContext<R extends AbstractFlinkResource<?,?>>	Context for Flink resource Event listener methods.
static interface	FlinkResourceListener.StatusUpdateContext<R extends AbstractFlinkResource<?,S>,S extends CommonStatus<?>>	Context for Flink resource Status listener methods.

Method Summary

Modifier and Type	Method	Description
void	onDeploymentEvent(FlinkResourceListener.ResourceEventContext<FlinkDeployment> ctx)
void	onDeploymentStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkDeployment,FlinkDeploymentStatus> ctx)
void	onSessionJobEvent(FlinkResourceListener.ResourceEventContext<FlinkSessionJob> ctx)
void	onSessionJobStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkSessionJob,FlinkSessionJobStatus> ctx)
void	onStateSnapshotEvent(FlinkResourceListener.FlinkStateSnapshotEventContext ctx)	Called when a new FlinkStateSnapshot event is triggered.
void	onStateSnapshotStatusUpdate(FlinkResourceListener.FlinkStateSnapshotStatusUpdateContext ctx)	Called when a FlinkStateSnapshot status gets updated.

Methods inherited from interface org.apache.flink.core.plugin.Plugin

configure, getClassLoader

Method Detail

onDeploymentStatusUpdate

void onDeploymentStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkDeployment,FlinkDeploymentStatus> ctx)

onDeploymentEvent

void onDeploymentEvent(FlinkResourceListener.ResourceEventContext<FlinkDeployment> ctx)

onSessionJobStatusUpdate

void onSessionJobStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkSessionJob,FlinkSessionJobStatus> ctx)

onSessionJobEvent

void onSessionJobEvent(FlinkResourceListener.ResourceEventContext<FlinkSessionJob> ctx)

onStateSnapshotEvent

void onStateSnapshotEvent(FlinkResourceListener.FlinkStateSnapshotEventContext ctx)

Called when a new FlinkStateSnapshot event is triggered.

Parameters:

ctx - Context of the event and resource

onStateSnapshotStatusUpdate

void onStateSnapshotStatusUpdate(FlinkResourceListener.FlinkStateSnapshotStatusUpdateContext ctx)

Called when a FlinkStateSnapshot status gets updated.

Parameters:

ctx - Context of the new status and resource