Package org.apache.flink.api.common.operators.util

Class OperatorValidationUtils

java.lang.Object

org.apache.flink.api.common.operators.util.OperatorValidationUtils

public class OperatorValidationUtils
extends Object

Utils for checking operators' resource and parallelism settings.

Method Summary

Modifier and Type	Method	Description
static void	validateMaxParallelism(int maxParallelism)
static void	validateMaxParallelism(int maxParallelism, boolean canBeParallel)
static void	validateMaxParallelism(int maxParallelism, int upperBound)
static void	validateMaxParallelism(int maxParallelism, int upperBound, boolean canBeParallel)
static void	validateMinAndPreferredResources(ResourceSpec minResources, ResourceSpec preferredResources)
static void	validateParallelism(int parallelism)
static void	validateParallelism(int parallelism, boolean canBeParallel)
static void	validateResources(ResourceSpec resources)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

validateParallelism

public static void validateParallelism(int parallelism)

validateParallelism

public static void validateParallelism(int parallelism,
                                       boolean canBeParallel)

validateMaxParallelism

public static void validateMaxParallelism(int maxParallelism)

validateMaxParallelism

public static void validateMaxParallelism(int maxParallelism,
                                          int upperBound)

validateMaxParallelism

public static void validateMaxParallelism(int maxParallelism,
                                          boolean canBeParallel)

validateMaxParallelism

public static void validateMaxParallelism(int maxParallelism,
                                          int upperBound,
                                          boolean canBeParallel)

validateResources

public static void validateResources(ResourceSpec resources)

validateMinAndPreferredResources

public static void validateMinAndPreferredResources(ResourceSpec minResources,
                                                    ResourceSpec preferredResources)