Package | Description |
---|---|
org.apache.flink.runtime.rest.handler.job | |
org.apache.flink.runtime.rest.messages.job |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSubtaskAttemptHandler<R extends ResponseBody,M extends SubtaskAttemptMessageParameters>
Base class for request handlers whose response depends on a specific attempt (defined
via the "
SubtaskAttemptPathParameter.KEY " of 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 SubtaskExecutionAttemptAccumulatorsInfo |
SubtaskExecutionAttemptAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody,SubtaskAttemptMessageParameters> request,
AccessExecution execution) |
protected SubtaskExecutionAttemptDetailsInfo |
SubtaskExecutionAttemptDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,SubtaskAttemptMessageParameters> request,
AccessExecution execution) |
Modifier and Type | Method and Description |
---|---|
SubtaskAttemptMessageParameters |
SubtaskExecutionAttemptDetailsHeaders.getUnresolvedMessageParameters() |
SubtaskAttemptMessageParameters |
SubtaskExecutionAttemptAccumulatorsHeaders.getUnresolvedMessageParameters() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.