Package org.apache.flink.autoscaler

Class DelayedScaleDown

java.lang.Object

org.apache.flink.autoscaler.DelayedScaleDown

public class DelayedScaleDown
extends java.lang.Object

All delayed scale down requests.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DelayedScaleDown.VertexDelayedScaleDownInfo	The delayed scale down info for vertex.

Constructor Summary

Constructors

Constructor	Description
DelayedScaleDown()

Method Summary

Modifier and Type	Method	Description
DelayedScaleDown.VertexDelayedScaleDownInfo	triggerScaleDown(org.apache.flink.runtime.jobgraph.JobVertexID vertex, java.time.Instant triggerTime, int parallelism)	Trigger a scale down, and return the corresponding DelayedScaleDown.VertexDelayedScaleDownInfo.

Methods inherited from class java.lang.Object

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

Constructor Detail

DelayedScaleDown

public DelayedScaleDown()

Method Detail

triggerScaleDown

@Nonnull
public DelayedScaleDown.VertexDelayedScaleDownInfo triggerScaleDown(org.apache.flink.runtime.jobgraph.JobVertexID vertex,
                                                                    java.time.Instant triggerTime,
                                                                    int parallelism)

Trigger a scale down, and return the corresponding DelayedScaleDown.VertexDelayedScaleDownInfo.