Uses of Class
org.apache.flink.autoscaler.DelayedScaleDown
-
Packages that use DelayedScaleDown Package Description org.apache.flink.autoscaler org.apache.flink.autoscaler.jdbc.state org.apache.flink.autoscaler.state org.apache.flink.kubernetes.operator.autoscaler.state -
-
Uses of DelayedScaleDown in org.apache.flink.autoscaler
Methods in org.apache.flink.autoscaler with parameters of type DelayedScaleDown Modifier and Type Method Description JobVertexScaler.ParallelismChange
JobVertexScaler. computeScaleTargetParallelism(Context context, org.apache.flink.runtime.jobgraph.JobVertexID vertex, java.util.Collection<ShipStrategy> inputShipStrategies, java.util.Map<ScalingMetric,EvaluatedScalingMetric> evaluatedMetrics, java.util.SortedMap<java.time.Instant,ScalingSummary> history, java.time.Duration restartTime, DelayedScaleDown delayedScaleDown)
boolean
ScalingExecutor. scaleResource(Context context, EvaluatedMetrics evaluatedMetrics, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.SortedMap<java.time.Instant,ScalingSummary>> scalingHistory, ScalingTracking scalingTracking, java.time.Instant now, JobTopology jobTopology, DelayedScaleDown delayedScaleDown)
-
Uses of DelayedScaleDown in org.apache.flink.autoscaler.jdbc.state
Methods in org.apache.flink.autoscaler.jdbc.state that return DelayedScaleDown Modifier and Type Method Description DelayedScaleDown
JdbcAutoScalerStateStore. getDelayedScaleDown(Context jobContext)
Methods in org.apache.flink.autoscaler.jdbc.state with parameters of type DelayedScaleDown Modifier and Type Method Description void
JdbcAutoScalerStateStore. storeDelayedScaleDown(Context jobContext, DelayedScaleDown delayedScaleDown)
-
Uses of DelayedScaleDown in org.apache.flink.autoscaler.state
Methods in org.apache.flink.autoscaler.state that return DelayedScaleDown Modifier and Type Method Description DelayedScaleDown
AutoScalerStateStore. getDelayedScaleDown(Context jobContext)
DelayedScaleDown
InMemoryAutoScalerStateStore. getDelayedScaleDown(Context jobContext)
Methods in org.apache.flink.autoscaler.state with parameters of type DelayedScaleDown Modifier and Type Method Description void
AutoScalerStateStore. storeDelayedScaleDown(Context jobContext, DelayedScaleDown delayedScaleDown)
void
InMemoryAutoScalerStateStore. storeDelayedScaleDown(Context jobContext, DelayedScaleDown delayedScaleDown)
-
Uses of DelayedScaleDown in org.apache.flink.kubernetes.operator.autoscaler.state
Methods in org.apache.flink.kubernetes.operator.autoscaler.state that return DelayedScaleDown Modifier and Type Method Description DelayedScaleDown
KubernetesAutoScalerStateStore. getDelayedScaleDown(KubernetesJobAutoScalerContext jobContext)
Methods in org.apache.flink.kubernetes.operator.autoscaler.state with parameters of type DelayedScaleDown Modifier and Type Method Description void
KubernetesAutoScalerStateStore. storeDelayedScaleDown(KubernetesJobAutoScalerContext jobContext, DelayedScaleDown delayedScaleDown)
-