org.apache.flink.runtime.rest.handler.job.rescaling

Class RescalingHandlers

java.lang.Object

org.apache.flink.runtime.rest.handler.async.AbstractAsynchronousOperationHandlers<AsynchronousJobOperationKey,Acknowledge>

org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers

public class RescalingHandlers
extends AbstractAsynchronousOperationHandlers<AsynchronousJobOperationKey,Acknowledge>

Rest handler to trigger and poll the rescaling of a running job.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	RescalingHandlers.RescalingStatusHandler Handler which reports the status of the rescaling operation.
class	RescalingHandlers.RescalingTriggerHandler Handler which triggers the rescaling of the specified job.

Nested classes/interfaces inherited from class org.apache.flink.runtime.rest.handler.async.AbstractAsynchronousOperationHandlers

AbstractAsynchronousOperationHandlers.StatusHandler<T extends RestfulGateway,V,M extends MessageParameters>, AbstractAsynchronousOperationHandlers.TriggerHandler<T extends RestfulGateway,B extends RequestBody,M extends MessageParameters>

Constructor Summary

Constructors

Constructor and Description
RescalingHandlers(java.time.Duration cacheDuration)

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

RescalingHandlers

public RescalingHandlers(java.time.Duration cacheDuration)