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

Class DefaultValidator

java.lang.Object

org.apache.flink.kubernetes.operator.validation.DefaultValidator

All Implemented Interfaces:

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

public class DefaultValidator
extends java.lang.Object
implements FlinkResourceValidator

Default validator implementation for FlinkDeployment.

Constructor Summary

Constructors

Constructor	Description
DefaultValidator(FlinkConfigManager configManager)

Method Summary

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> sessionOpt)	Validate and return optional error.

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

DefaultValidator

public DefaultValidator(FlinkConfigManager configManager)

Method Detail

validateDeployment

public java.util.Optional<java.lang.String> validateDeployment(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment)

Description copied from interface: FlinkResourceValidator

Validate and return optional error.

Specified by:

validateDeployment in interface FlinkResourceValidator

Parameters:

deployment - A Flink application or session cluster deployment.

Returns:

Optional error string, should be present iff validation resulted in an error

validateSessionJob

public 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> sessionOpt)

Description copied from interface: FlinkResourceValidator

Validate and return optional error.

Specified by:

validateSessionJob in interface FlinkResourceValidator

Parameters:

sessionJob - the session job to be validated.

sessionOpt - the target session cluster of the session job to be validated.

Returns:

Optional error string, should be present iff validation resulted in an error