org.apache.flink.runtime.rest.handler.legacy

Class JobVertexBackPressureHandler

java.lang.Object

org.apache.flink.runtime.rest.handler.legacy.AbstractJsonRequestHandler

org.apache.flink.runtime.rest.handler.legacy.AbstractExecutionGraphRequestHandler

org.apache.flink.runtime.rest.handler.legacy.AbstractJobVertexRequestHandler

org.apache.flink.runtime.rest.handler.legacy.JobVertexBackPressureHandler

All Implemented Interfaces:

RequestHandler

public class JobVertexBackPressureHandler
extends AbstractJobVertexRequestHandler

Request handler that returns back pressure stats for a single job vertex and all its sub tasks.

Field Summary

Fields inherited from class org.apache.flink.runtime.rest.handler.legacy.AbstractJsonRequestHandler

executor

Constructor Summary

Constructors

Constructor and Description
JobVertexBackPressureHandler(ExecutionGraphCache executionGraphHolder, Executor executor, BackPressureStatsTracker backPressureStatsTracker, int refreshInterval)

Method Summary

Modifier and Type	Method and Description
String[]	getPaths() Returns an array of REST URL's under which this handler can be registered.
CompletableFuture<String>	handleRequest(AccessExecutionJobVertex accessJobVertex, Map<String,String> params)

Methods inherited from class org.apache.flink.runtime.rest.handler.legacy.AbstractJobVertexRequestHandler

handleRequest, parseJobVertexId

Methods inherited from class org.apache.flink.runtime.rest.handler.legacy.AbstractExecutionGraphRequestHandler

handleJsonRequest

Methods inherited from class org.apache.flink.runtime.rest.handler.legacy.AbstractJsonRequestHandler

handleRequest

Methods inherited from class java.lang.Object

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

Constructor Detail

JobVertexBackPressureHandler

public JobVertexBackPressureHandler(ExecutionGraphCache executionGraphHolder,
                                    Executor executor,
                                    BackPressureStatsTracker backPressureStatsTracker,
                                    int refreshInterval)

Method Detail

getPaths

public String[] getPaths()

Description copied from interface: RequestHandler

Returns an array of REST URL's under which this handler can be registered.

Returns:

array containing REST URL's under which this handler can be registered.

handleRequest

public CompletableFuture<String> handleRequest(AccessExecutionJobVertex accessJobVertex,
                                               Map<String,String> params)

Specified by:

handleRequest in class AbstractJobVertexRequestHandler