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 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.