org.apache.flink.runtime.scheduler

Class ExecutionVertexSchedulingRequirements.Builder

java.lang.Object

org.apache.flink.runtime.scheduler.ExecutionVertexSchedulingRequirements.Builder

Enclosing class:

ExecutionVertexSchedulingRequirements

public static class ExecutionVertexSchedulingRequirements.Builder
extends Object

Builder for ExecutionVertexSchedulingRequirements.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
ExecutionVertexSchedulingRequirements	build()
ExecutionVertexSchedulingRequirements.Builder	withCoLocationConstraint(CoLocationConstraint coLocationConstraint)
ExecutionVertexSchedulingRequirements.Builder	withExecutionVertexId(ExecutionVertexID executionVertexId)
ExecutionVertexSchedulingRequirements.Builder	withPhysicalSlotResourceProfile(ResourceProfile physicalSlotResourceProfile)
ExecutionVertexSchedulingRequirements.Builder	withPreferredLocations(Collection<TaskManagerLocation> preferredLocations)
ExecutionVertexSchedulingRequirements.Builder	withPreviousAllocationId(AllocationID previousAllocationId)
ExecutionVertexSchedulingRequirements.Builder	withSlotSharingGroupId(SlotSharingGroupId slotSharingGroupId)
ExecutionVertexSchedulingRequirements.Builder	withTaskResourceProfile(ResourceProfile taskResourceProfile)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

withExecutionVertexId

public ExecutionVertexSchedulingRequirements.Builder withExecutionVertexId(ExecutionVertexID executionVertexId)

withPreviousAllocationId

public ExecutionVertexSchedulingRequirements.Builder withPreviousAllocationId(AllocationID previousAllocationId)

withTaskResourceProfile

public ExecutionVertexSchedulingRequirements.Builder withTaskResourceProfile(ResourceProfile taskResourceProfile)

withPhysicalSlotResourceProfile

public ExecutionVertexSchedulingRequirements.Builder withPhysicalSlotResourceProfile(ResourceProfile physicalSlotResourceProfile)

withSlotSharingGroupId

public ExecutionVertexSchedulingRequirements.Builder withSlotSharingGroupId(SlotSharingGroupId slotSharingGroupId)

withCoLocationConstraint

public ExecutionVertexSchedulingRequirements.Builder withCoLocationConstraint(CoLocationConstraint coLocationConstraint)

withPreferredLocations

public ExecutionVertexSchedulingRequirements.Builder withPreferredLocations(Collection<TaskManagerLocation> preferredLocations)

build

public ExecutionVertexSchedulingRequirements build()