Package org.apache.flink.kubernetes.operator.mutator

Class DefaultFlinkMutator

java.lang.Object

org.apache.flink.kubernetes.operator.mutator.DefaultFlinkMutator

All Implemented Interfaces:

org.apache.flink.core.plugin.Plugin, FlinkResourceMutator

public class DefaultFlinkMutator
extends java.lang.Object
implements FlinkResourceMutator

Default Flink Mutator.

Constructor Summary

Constructors

Constructor	Description
DefaultFlinkMutator()

Method Summary

Modifier and Type	Method	Description
FlinkDeployment	mutateDeployment(FlinkDeployment deployment)	Mutate deployment and return the mutated Object.
FlinkSessionJob	mutateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<FlinkDeployment> session)	Mutate session job and return the mutated Object.

Methods inherited from class java.lang.Object

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

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

configure, getClassLoader

Constructor Detail

DefaultFlinkMutator

public DefaultFlinkMutator()

Method Detail

mutateDeployment

public FlinkDeployment mutateDeployment(FlinkDeployment deployment)

Description copied from interface: FlinkResourceMutator

Mutate deployment and return the mutated Object.

Specified by:

mutateDeployment in interface FlinkResourceMutator

Parameters:

deployment - A Flink application or session cluster deployment.

mutateSessionJob

public FlinkSessionJob mutateSessionJob(FlinkSessionJob sessionJob,
                                        java.util.Optional<FlinkDeployment> session)

Description copied from interface: FlinkResourceMutator

Mutate session job and return the mutated Object.

Specified by:

mutateSessionJob in interface FlinkResourceMutator

Parameters:

sessionJob - the session job to be mutated.

session - the target session cluster of the session job to be Mutated.