Package | Description |
---|---|
org.apache.flink.runtime.messages.webmonitor |
This package contains the actor messages that are sent between the
JobManager and components that are interested in the status of
the JobManager.
|
org.apache.flink.runtime.rest | |
org.apache.flink.runtime.rest.handler | |
org.apache.flink.runtime.rest.handler.async | |
org.apache.flink.runtime.rest.handler.job | |
org.apache.flink.runtime.rest.handler.job.checkpoints | |
org.apache.flink.runtime.rest.handler.legacy.messages | |
org.apache.flink.runtime.rest.handler.util | |
org.apache.flink.runtime.rest.messages | |
org.apache.flink.runtime.rest.messages.checkpoints | |
org.apache.flink.runtime.rest.messages.job | |
org.apache.flink.runtime.rest.messages.job.metrics | |
org.apache.flink.runtime.rest.messages.job.savepoints | |
org.apache.flink.runtime.rest.messages.queue | |
org.apache.flink.runtime.rest.messages.taskmanager | |
org.apache.flink.runtime.webmonitor.handlers | |
org.apache.flink.runtime.webmonitor.history |
Modifier and Type | Class and Description |
---|---|
class |
JobIdsWithStatusOverview
An overview of how many jobs are in which status.
|
class |
MultipleJobsDetails
An actor messages describing details of various jobs.
|
Modifier and Type | Method and Description |
---|---|
<M extends MessageHeaders<R,P,U>,U extends MessageParameters,R extends RequestBody,P extends ResponseBody> |
RestClient.sendRequest(String targetAddress,
int targetPort,
M messageHeaders,
U messageParameters,
R request) |
<M extends MessageHeaders<R,P,U>,U extends MessageParameters,R extends RequestBody,P extends ResponseBody> |
RestClient.sendRequest(String targetAddress,
int targetPort,
M messageHeaders,
U messageParameters,
R request,
Collection<FileUpload> fileUploads) |
<M extends MessageHeaders<R,P,U>,U extends MessageParameters,R extends RequestBody,P extends ResponseBody> |
RestClient.sendRequest(String targetAddress,
int targetPort,
M messageHeaders,
U messageParameters,
R request,
Collection<FileUpload> fileUploads,
RestAPIVersion apiVersion) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRestHandler<T extends RestfulGateway,R extends RequestBody,P extends ResponseBody,M extends MessageParameters>
Super class for netty-based handlers that work with
RequestBody s and ResponseBody s. |
Modifier and Type | Class and Description |
---|---|
class |
AsynchronousOperationResult<V>
Result of an asynchronous operation.
|
class |
TriggerResponse
Response to the triggering of an asynchronous operation.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters>
Base class for all
AccessExecutionGraph based REST handlers. |
class |
AbstractJobVertexHandler<R extends ResponseBody,M extends JobVertexMessageParameters>
Base class for request handlers whose response depends on a specific job vertex (defined
via the "
JobVertexIdPathParameter.KEY " parameter) in a specific job,
defined via (defined via the "JobIDPathParameter.KEY " parameter). |
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). |
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 | Class and Description |
---|---|
class |
AbstractCheckpointHandler<R extends ResponseBody,M extends CheckpointMessageParameters>
Base class for checkpoint related REST handler.
|
Modifier and Type | Class and Description |
---|---|
class |
ClusterOverviewWithVersion
Cluster overview message including the current Flink version and commit id.
|
Modifier and Type | Method and Description |
---|---|
static <P extends ResponseBody> |
HandlerUtils.sendResponse(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext channelHandlerContext,
org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpRequest httpRequest,
P response,
org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseStatus statusCode,
Map<String,String> headers)
Sends the given response and status code to the given channel.
|
Modifier and Type | Interface and Description |
---|---|
interface |
MessageHeaders<R extends RequestBody,P extends ResponseBody,M extends MessageParameters>
This class links
RequestBody s to ResponseBody s types and contains meta-data required for their http headers. |
Modifier and Type | Class and Description |
---|---|
class |
ClusterConfigurationInfo
Response of the
ClusterConfigHandler , represented as a list
of key-value pairs of the cluster Configuration . |
class |
DashboardConfiguration
Response of the
DashboardConfigHandler containing general configuration
values such as the time zone and the refresh interval. |
class |
EmptyResponseBody
Empty
ResponseBody implementation. |
class |
ErrorResponseBody
Generic response body for communicating errors on the server.
|
class |
JobAccumulatorsInfo
Response type of the
JobAccumulatorsHandler . |
class |
JobConfigInfo
Response type of the
JobConfigHandler . |
class |
JobExceptionsInfo
Response type of the
JobExceptionsHandler . |
class |
JobPlanInfo
Response type of the
JobPlanHandler . |
class |
JobVertexAccumulatorsInfo
Response type of the
JobVertexAccumulatorsHandler . |
class |
JobVertexBackPressureInfo
Response type of the
JobVertexBackPressureHandler . |
class |
JobVertexDetailsInfo
Response type of the
JobVertexDetailsHandler . |
class |
JobVertexTaskManagersInfo
Response type of the
JobVertexTaskManagersHandler . |
class |
SubtasksTimesInfo
Response type of the
SubtasksTimesHandler . |
Modifier and Type | Class and Description |
---|---|
class |
CheckpointConfigInfo
Response class of the
CheckpointConfigHandler . |
class |
CheckpointingStatistics
Response of the
CheckpointingStatisticsHandler . |
class |
CheckpointStatistics
Statistics for a checkpoint.
|
static class |
CheckpointStatistics.CompletedCheckpointStatistics
Statistics for a completed checkpoint.
|
static class |
CheckpointStatistics.FailedCheckpointStatistics
Statistics for a failed checkpoint.
|
static class |
CheckpointStatistics.PendingCheckpointStatistics
Statistics for a pending checkpoint.
|
class |
TaskCheckpointStatistics
Checkpoint statistics for a single task.
|
class |
TaskCheckpointStatisticsWithSubtaskDetails
Task checkpoint statistics which also includes information about the sub task
checkpoint statistics.
|
Modifier and Type | Class and Description |
---|---|
class |
JobDetailsInfo
Details about a job.
|
class |
JobExecutionResultResponseBody
|
class |
JobSubmitResponseBody
Response to the submission of a job, containing a URL from which the status of the job can be retrieved from.
|
class |
SubtaskExecutionAttemptAccumulatorsInfo
Response type of the
SubtaskExecutionAttemptAccumulatorsHandler . |
class |
SubtaskExecutionAttemptDetailsInfo
The sub task execution attempt response.
|
class |
SubtasksAllAccumulatorsInfo
Response type of the
SubtasksAllAccumulatorsHandler . |
Modifier and Type | Class and Description |
---|---|
class |
AggregatedMetricsResponseBody
Response type for a collection of aggregated metrics.
|
class |
MetricCollectionResponseBody
Response type for a collection of metrics.
|
Modifier and Type | Class and Description |
---|---|
class |
SavepointInfo
Represents information about a finished savepoint.
|
Modifier and Type | Interface and Description |
---|---|
interface |
AsynchronouslyCreatedResource<T>
Interface for REST resources that are created asynchronously.
|
Modifier and Type | Class and Description |
---|---|
class |
TaskManagerDetailsInfo
Message containing base information about a
TaskExecutor and more
detailed metrics. |
class |
TaskManagerInfo
Base class containing information for a
TaskExecutor . |
class |
TaskManagersInfo
Class containing a collection of
TaskManagerInfo . |
Modifier and Type | Class and Description |
---|---|
class |
JarListInfo
Response type of the
JarListHandler . |
class |
JarRunResponseBody
Response for
JarRunHandler . |
class |
JarUploadResponseBody
|
Constructor and Description |
---|
ArchivedJson(String path,
ResponseBody json) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.