Modifier and Type | Method and Description |
---|---|
<M extends MessageHeaders<R,P,U>,U extends MessageParameters,R extends RequestBody,P extends ResponseBody> |
RestClusterClient.sendRequest(M messageHeaders,
U messageParameters,
R request) |
Modifier and Type | Class and Description |
---|---|
class |
JobIdsWithStatusOverview
An overview of how many jobs are in which status.
|
class |
JobStatusInfo
The status of a specific job.
|
class |
MultipleJobsDetails
An actor messages describing details of various jobs.
|
Modifier and Type | Method and Description |
---|---|
<M extends MessageHeaders<EmptyRequestBody,P,EmptyMessageParameters>,P extends ResponseBody> |
RestClient.sendRequest(String targetAddress,
int targetPort,
M messageHeaders) |
<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<? extends 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 |
AbstractAccessExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters>
AbstractAccessExecutionGraphHandler handles requests that require accessing the job's
AccessExecutionGraph . |
class |
AbstractExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters>
Base class for all
ExecutionGraphInfo 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 | Class and Description |
---|---|
class |
AbstractResourceManagerHandler<T extends RestfulGateway,R extends RequestBody,P extends ResponseBody,M extends MessageParameters>
Base class for REST handlers which need access to the
ResourceManager . |
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. |
interface |
RuntimeMessageHeaders<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 in runtime module. |
Modifier and Type | Class and Description |
---|---|
class |
AggregatedTaskDetailsInfo
Aggregated info of a set of tasks.
|
class |
ConfigurationInfo
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 |
EnvironmentInfo
The response of environment info.
|
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 |
JobExceptionsInfoWithHistory
JobExceptionsInfoWithHistory extends JobExceptionsInfo providing a history of
previously caused failures. |
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 |
LogListInfo
Class containing a collection of
LogInfo . |
class |
LogUrlResponse
Response of log URLs.
|
class |
ResourceProfileInfo
Contains information of a
ResourceProfile . |
class |
SubtasksTimesInfo
Response type of the
SubtasksTimesHandler . |
class |
ThreadDumpInfo
Class containing thread dump information.
|
Modifier and Type | Class and Description |
---|---|
class |
CheckpointConfigInfo
Response class of the
CheckpointConfigHandler . |
class |
CheckpointInfo
Represents information about a triggered checkpoint.
|
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 |
ClusterDataSetListResponseBody
|
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 |
ClientCoordinationResponseBody
Response that carries a serialized
CoordinationResponse to the client. |
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 |
SlotInfo
Class containing information for a slot of
TaskManagerSlotInformation . |
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) |
Modifier and Type | Class and Description |
---|---|
class |
JobVertexFlameGraph
Flame Graph representation for a job vertex.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractSqlGatewayRestHandler<R extends RequestBody,P extends ResponseBody,M extends MessageParameters>
Super class for sql gateway handlers that work with
RequestBody s and ResponseBody s. |
Modifier and Type | Interface and Description |
---|---|
interface |
SqlGatewayMessageHeaders<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 in runtime module. |
Modifier and Type | Class and Description |
---|---|
class |
OperationStatusResponseBody
ResponseBody for getting the status of operation. |
Modifier and Type | Class and Description |
---|---|
class |
CloseSessionResponseBody
ResponseBody for closing a session. |
class |
GetSessionConfigResponseBody
ResponseBody for get session configuration. |
class |
OpenSessionResponseBody
ResponseBody for opening a session. |
Modifier and Type | Class and Description |
---|---|
class |
ExecuteStatementResponseBody
ResponseBody for execute a statement. |
class |
FetchResultsResponseBody
ResponseBody for execute a statement. |
Modifier and Type | Class and Description |
---|---|
class |
GetApiVersionResponseBody
ResponseBody for getting rest api version. |
class |
GetInfoResponseBody
ResponseBody for getting cluster information. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.