org.apache.flink.runtime.scheduler

Class ExecutionVertexSchedulingRequirementsMapper

java.lang.Object

org.apache.flink.runtime.scheduler.ExecutionVertexSchedulingRequirementsMapper

public final class ExecutionVertexSchedulingRequirementsMapper
extends Object

Class that creates ExecutionVertexSchedulingRequirements for an ExecutionVertex.

Method Summary

Modifier and Type	Method and Description
static ExecutionVertexSchedulingRequirements	from(ExecutionVertex executionVertex)
static ResourceProfile	getPhysicalSlotResourceProfile(ExecutionVertex executionVertex) Get resource profile of the physical slot to allocate a logical slot in for the given vertex.

Methods inherited from class java.lang.Object

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

Method Detail

from

public static ExecutionVertexSchedulingRequirements from(ExecutionVertex executionVertex)

getPhysicalSlotResourceProfile

public static ResourceProfile getPhysicalSlotResourceProfile(ExecutionVertex executionVertex)

Get resource profile of the physical slot to allocate a logical slot in for the given vertex. If the vertex is in a slot sharing group, the physical slot resource profile should be the resource profile of the slot sharing group. Otherwise it should be the resource profile of the vertex itself since the physical slot would be used by this vertex only in this case.

Returns:

resource profile of the physical slot to allocate a logical slot for the given vertex