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

Modifier and Type	Method	Description
java.util.Optional<java.lang.String>	validateDeployment(FlinkDeployment deployment)	Validate and return optional error.
java.util.Optional<java.lang.String>	validateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<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(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(FlinkSessionJob sessionJob,
                                                        java.util.Optional<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