Package | Description |
---|---|
org.apache.flink.runtime.rest.handler.job | |
org.apache.flink.runtime.rest.messages.job | |
org.apache.flink.runtime.rest.messages.job.metrics |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSubtaskHandler<R extends ResponseBody,M extends SubtaskMessageParameters>
Base class for request handlers whose response depends on a specific subtask (defined via the
"
SubtaskIndexPathParameter.KEY " in a specific job vertex, (defined via the "JobVertexIdPathParameter.KEY " parameter) in a specific job, defined via (defined via the "JobIDPathParameter.KEY " parameter). |
Modifier and Type | Method and Description |
---|---|
protected SubtaskExecutionAttemptDetailsInfo |
SubtaskCurrentAttemptDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,SubtaskMessageParameters> request,
AccessExecutionVertex executionVertex) |
Constructor and Description |
---|
SubtaskCurrentAttemptDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
MetricFetcher metricFetcher) |
Modifier and Type | Class and Description |
---|---|
class |
SubtaskAttemptMessageParameters
The type Subtask attempt message parameters.
|
Modifier and Type | Method and Description |
---|---|
SubtaskMessageParameters |
SubtaskCurrentAttemptDetailsHeaders.getUnresolvedMessageParameters() |
Modifier and Type | Class and Description |
---|---|
class |
SubtaskMetricsMessageParameters
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.