Package org.apache.flink.runtime.scheduler

Class DefaultVertexParallelismInfo

java.lang.Object

org.apache.flink.runtime.scheduler.DefaultVertexParallelismInfo

All Implemented Interfaces:

VertexParallelismInformation

public class DefaultVertexParallelismInfo
extends Object
implements VertexParallelismInformation

A VertexParallelismInformation implementation that provides common validation.

Constructor Summary

Constructors

Constructor	Description
DefaultVertexParallelismInfo(int minParallelism, int parallelism, int maxParallelism, java.util.function.Function<Integer,Optional<String>> rescaleMaxValidator)
DefaultVertexParallelismInfo(int parallelism, int maxParallelism, java.util.function.Function<Integer,Optional<String>> rescaleMaxValidator)	Create VertexParallelismInformation with max parallelism rescaling validation for a vertex.

Method Summary

Modifier and Type	Method	Description
boolean	canRescaleMaxParallelism(int desiredMaxParallelism)	Returns whether the vertex's max parallelism can be changed to a given value.
int	getMaxParallelism()	Returns the vertex's max parallelism.
int	getMinParallelism()	Returns a vertex's min parallelism.
int	getParallelism()	Returns a vertex's parallelism.
void	setMaxParallelism(int maxParallelism)	Changes a given vertex's max parallelism property.
void	setParallelism(int parallelism)	Set a given vertex's parallelism property.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultVertexParallelismInfo

public DefaultVertexParallelismInfo(int parallelism,
                                    int maxParallelism,
                                    java.util.function.Function<Integer,Optional<String>> rescaleMaxValidator)

Create VertexParallelismInformation with max parallelism rescaling validation for a vertex.

Parameters:

parallelism - the vertex's parallelism

maxParallelism - the vertex's max parallelism

rescaleMaxValidator - the validation function to provide an error message if a max parallelism rescale is not allowed

DefaultVertexParallelismInfo

public DefaultVertexParallelismInfo(int minParallelism,
                                    int parallelism,
                                    int maxParallelism,
                                    java.util.function.Function<Integer,Optional<String>> rescaleMaxValidator)

Method Detail

getMinParallelism

public int getMinParallelism()

Description copied from interface: VertexParallelismInformation

Returns a vertex's min parallelism.

Specified by:

getMinParallelism in interface VertexParallelismInformation

Returns:

the min parallelism for the vertex

getParallelism

public int getParallelism()

Description copied from interface: VertexParallelismInformation

Returns a vertex's parallelism.

Specified by:

getParallelism in interface VertexParallelismInformation

Returns:

the parallelism for the vertex

getMaxParallelism

public int getMaxParallelism()

Description copied from interface: VertexParallelismInformation

Returns the vertex's max parallelism.

Specified by:

getMaxParallelism in interface VertexParallelismInformation

Returns:

the max parallelism for the vertex

setParallelism

public void setParallelism(int parallelism)

Description copied from interface: VertexParallelismInformation

Set a given vertex's parallelism property. The parallelism can be changed only if the vertex parallelism was not decided yet (i.e. was -1).

Specified by:

setParallelism in interface VertexParallelismInformation

Parameters:

parallelism - the parallelism for the vertex

setMaxParallelism

public void setMaxParallelism(int maxParallelism)

Description copied from interface: VertexParallelismInformation

Changes a given vertex's max parallelism property. The caller should first check the validity of the new setting via VertexParallelismInformation.canRescaleMaxParallelism(int), otherwise this operation may fail.

Specified by:

setMaxParallelism in interface VertexParallelismInformation

Parameters:

maxParallelism - the new max parallelism for the vertex

canRescaleMaxParallelism

public boolean canRescaleMaxParallelism(int desiredMaxParallelism)

Description copied from interface: VertexParallelismInformation

Returns whether the vertex's max parallelism can be changed to a given value.

Specified by:

canRescaleMaxParallelism in interface VertexParallelismInformation

Parameters:

desiredMaxParallelism - the desired max parallelism for the vertex

Returns:

whether the max parallelism can be changed to the given value