Uses of Class
org.apache.flink.runtime.rest.messages.job.SubtaskAttemptMessageParameters

Packages that use SubtaskAttemptMessageParameters

Package	Description
org.apache.flink.runtime.rest.handler.job
org.apache.flink.runtime.rest.messages.job

Uses of SubtaskAttemptMessageParameters in org.apache.flink.runtime.rest.handler.job

Classes in org.apache.flink.runtime.rest.handler.job with type parameters of type SubtaskAttemptMessageParameters

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).

Method parameters in org.apache.flink.runtime.rest.handler.job with type arguments of type SubtaskAttemptMessageParameters

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)

Constructor parameters in org.apache.flink.runtime.rest.handler.job with type arguments of type SubtaskAttemptMessageParameters

Constructor and Description
SubtaskExecutionAttemptAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptAccumulatorsInfo,SubtaskAttemptMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor) Instantiates a new Abstract job vertex handler.
SubtaskExecutionAttemptDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskAttemptMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher) Instantiates a new subtask execution attempt details handler.

Uses of SubtaskAttemptMessageParameters in org.apache.flink.runtime.rest.messages.job

Methods in org.apache.flink.runtime.rest.messages.job that return SubtaskAttemptMessageParameters

Modifier and Type	Method and Description
SubtaskAttemptMessageParameters	SubtaskExecutionAttemptDetailsHeaders.getUnresolvedMessageParameters()
SubtaskAttemptMessageParameters	SubtaskExecutionAttemptAccumulatorsHeaders.getUnresolvedMessageParameters()