Package org.apache.flink.kubernetes.operator.validation

Interface FlinkResourceValidator

  • All Superinterfaces:
    org.apache.flink.core.plugin.Plugin
    All Known Implementing Classes:
    DefaultValidator
    public interface FlinkResourceValidator
extends org.apache.flink.core.plugin.Plugin
    Validator for different resources.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      java.util.Optional<java.lang.String> validateDeployment​(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment)
      Validate and return optional error.
      java.util.Optional<java.lang.String> validateSessionJob​(org.apache.flink.kubernetes.operator.api.FlinkSessionJob sessionJob, java.util.Optional<org.apache.flink.kubernetes.operator.api.FlinkDeployment> session)
      Validate and return optional error.

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

        configure, getClassLoader

    • Method Detail

      • validateDeployment

        java.util.Optional<java.lang.String> validateDeployment​(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment)
        Validate and return optional error.
        Parameters:
        deployment - A Flink application or session cluster deployment.
        Returns:
        Optional error string, should be present iff validation resulted in an error

      • validateSessionJob

        java.util.Optional<java.lang.String> validateSessionJob​(org.apache.flink.kubernetes.operator.api.FlinkSessionJob sessionJob,
                                                        java.util.Optional<org.apache.flink.kubernetes.operator.api.FlinkDeployment> session)
        Validate and return optional error.
        Parameters:
        sessionJob - the session job to be validated.
        session - the target session cluster of the session job to be validated.
        Returns:
        Optional error string, should be present iff validation resulted in an error