Interface FlinkResourceMutator
-
- All Superinterfaces:
org.apache.flink.core.plugin.Plugin
- All Known Implementing Classes:
DefaultFlinkMutator
public interface FlinkResourceMutator extends org.apache.flink.core.plugin.Plugin
Mutator for Flink Resources.
-
-
Method Summary
All Methods Instance Methods Abstract Methods 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.
-
-
-
Method Detail
-
mutateDeployment
FlinkDeployment mutateDeployment(FlinkDeployment deployment)
Mutate deployment and return the mutated Object.- Parameters:
deployment
- A Flink application or session cluster deployment.
-
mutateSessionJob
FlinkSessionJob mutateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<FlinkDeployment> session)
Mutate session job and return the mutated Object.- Parameters:
sessionJob
- the session job to be mutated.session
- the target session cluster of the session job to be Mutated.
-
-