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.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.savepoints |
Modifier and Type | Class and Description |
---|---|
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,EmptyMessageParameters>,R extends RequestBody,P extends ResponseBody> |
RestClient.sendRequest(String targetAddress,
int targetPort,
M messageHeaders,
R request) |
<M extends MessageHeaders<EmptyRequestBody,P,U>,U extends MessageParameters,P extends ResponseBody> |
RestClient.sendRequest(String targetAddress,
int targetPort,
M messageHeaders,
U messageParameters) |
<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) |
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. |
interface |
LegacyRestHandler<T extends RestfulGateway,R extends ResponseBody,M extends MessageParameters>
Interface which Flink's legacy REST handler have to implement in order to be usable
via the
LegacyRestHandlerAdapter . |
class |
LegacyRestHandlerAdapter<T extends RestfulGateway,R extends ResponseBody,M extends MessageParameters>
Adapter for Flink's legacy REST handlers.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters>
Base class for all
AccessExecutionGraph based REST handlers. |
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)
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 |
BlobServerPortResponseBody
Response containing the blob server port.
|
class |
ClusterConfigurationInfo
Response of the
ClusterConfigHandler , respresented 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 |
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 . |
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.
|
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 |
JobSubmitResponseBody
Response to the submission of a job, containing a URL from which the status of the job can be retrieved from.
|
Modifier and Type | Class and Description |
---|---|
class |
SavepointTriggerResponseBody
Response to the triggering of a savepoint.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.