org.apache.flink.runtime.resourcemanager.slotmanager

Class ResourceReconcileResult

java.lang.Object

org.apache.flink.runtime.resourcemanager.slotmanager.ResourceReconcileResult

public class ResourceReconcileResult
extends Object

Contains the results of the ResourceAllocationStrategy.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ResourceReconcileResult.Builder

Constructor Summary

Constructors

Constructor and Description
ResourceReconcileResult(List<PendingTaskManager> pendingTaskManagersToAllocate, List<PendingTaskManager> pendingTaskManagersToRelease, List<TaskManagerInfo> taskManagersToRelease)

Method Summary

Modifier and Type	Method and Description
static ResourceReconcileResult.Builder	builder()
List<PendingTaskManager>	getPendingTaskManagersToAllocate()
List<PendingTaskManager>	getPendingTaskManagersToRelease()
List<TaskManagerInfo>	getTaskManagersToRelease()
boolean	needReconcile() Returns whether the cluster resource need reconcile.

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceReconcileResult

public ResourceReconcileResult(List<PendingTaskManager> pendingTaskManagersToAllocate,
                               List<PendingTaskManager> pendingTaskManagersToRelease,
                               List<TaskManagerInfo> taskManagersToRelease)

Method Detail

getPendingTaskManagersToAllocate

public List<PendingTaskManager> getPendingTaskManagersToAllocate()

getPendingTaskManagersToRelease

public List<PendingTaskManager> getPendingTaskManagersToRelease()

getTaskManagersToRelease

public List<TaskManagerInfo> getTaskManagersToRelease()

needReconcile

public boolean needReconcile()

Returns whether the cluster resource need reconcile.

Returns:

True if the cluster resource need reconcile, otherwise false.

builder

public static ResourceReconcileResult.Builder builder()