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 | 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 |
AbstractHandler<T extends RestfulGateway,R extends RequestBody,M extends MessageParameters>
Super class for netty-based handlers that work with
RequestBody . |
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. |
class |
HandlerRequest<R extends RequestBody,M extends MessageParameters>
Simple container for the request to a handler, that contains the
RequestBody and
path/query parameters. |
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractAsynchronousOperationHandlers.StatusHandler<T extends RestfulGateway,V,M extends MessageParameters>
Handler which will be polled to retrieve the asynchronous operation's result.
|
protected class |
AbstractAsynchronousOperationHandlers.TriggerHandler<T extends RestfulGateway,B extends RequestBody,M extends MessageParameters>
Handler which is responsible for triggering an asynchronous operation.
|
class |
AsynchronousOperationStatusMessageHeaders<V,M extends MessageParameters>
Message headers for the status polling of an asynchronous operation.
|
class |
AsynchronousOperationTriggerMessageHeaders<R extends RequestBody,M extends MessageParameters>
Message headers for the triggering of an asynchronous operation.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractJobManagerFileHandler<M extends MessageParameters>
Base class for serving files from the JobManager.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMetricsHandler<M extends MessageParameters>
Request handler that returns for a given task a list of all available metrics or the values for a
set of metrics.
|
Modifier and Type | Class and Description |
---|---|
class |
RescalingStatusMessageParameters
MessageParameters for polling the status of a rescaling operation. |
class |
RescalingTriggerMessageParameters
MessageParameters for triggering the rescaling of a job. |
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 <X,P extends MessageQueryParameter<X>,R extends RequestBody,M extends MessageParameters> |
HandlerRequestUtils.getQueryParameter(HandlerRequest<R,M> request,
Class<P> queryParameterClass)
Returns the value of a query parameter, or
null if the query parameter is not set. |
static <X,P extends MessageQueryParameter<X>,R extends RequestBody,M extends MessageParameters> |
HandlerRequestUtils.getQueryParameter(HandlerRequest<R,M> request,
Class<P> queryParameterClass,
X defaultValue) |
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 |
UntypedResponseMessageHeaders<R extends RequestBody,M extends MessageParameters>
Message headers for a web handler request.
|
Modifier and Type | Class and Description |
---|---|
class |
EmptyMessageParameters
MessageParameters implementation which has no parameters.
|
class |
JobAccumulatorsMessageParameters
Request parameter for job accumulator's handler
JobAccumulatorsHandler . |
class |
JobCancellationMessageParameters
Parameters for job related REST handlers.
|
class |
JobMessageParameters
Message parameters which require a job path parameter.
|
class |
JobVertexMessageParameters
Message parameters for job vertex REST handlers.
|
Modifier and Type | Method and Description |
---|---|
static String |
MessageParameters.resolveUrl(String genericUrl,
MessageParameters parameters)
Resolves the given URL (e.g "jobs/:jobid") using the given path/query parameters.
|
Modifier and Type | Class and Description |
---|---|
class |
CheckpointMessageParameters
Message parameters for checkpoint related messages.
|
class |
TaskCheckpointMessageParameters
Message parameters for subtask related checkpoint message.
|
Modifier and Type | Class and Description |
---|---|
class |
FileMessageParameters
Parameters for
JobManagerCustomLogHandler . |
Modifier and Type | Class and Description |
---|---|
class |
ClusterDataSetDeleteStatusMessageParameters
|
class |
ClusterDataSetDeleteTriggerMessageParameters
|
Modifier and Type | Class and Description |
---|---|
class |
JobExceptionsMessageParameters
|
class |
SubtaskAttemptMessageParameters
The type Subtask attempt message parameters.
|
class |
SubtaskMessageParameters
Message parameters for subtask REST handlers.
|
Modifier and Type | Class and Description |
---|---|
class |
ClientCoordinationMessageParameters
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMetricsHeaders<M extends MessageParameters>
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractAggregatedMetricsParameters<M extends MessageQueryParameter<?>>
Base
MessageParameters class for aggregating metrics. |
class |
AggregatedJobMetricsParameters
Parameters for aggregating job metrics.
|
class |
AggregatedSubtaskMetricsParameters
Parameters for aggregating subtask metrics.
|
class |
AggregateTaskManagerMetricsParameters
Parameters for aggregating task manager metrics.
|
class |
JobManagerMetricsMessageParameters
|
class |
JobMetricsMessageParameters
|
class |
JobVertexMetricsMessageParameters
|
class |
SubtaskMetricsMessageParameters
|
class |
TaskManagerMetricsMessageParameters
|
Modifier and Type | Class and Description |
---|---|
class |
SavepointDisposalStatusMessageParameters
MessageParameters for the SavepointDisposalHandlers.SavepointDisposalStatusHandler . |
class |
SavepointStatusMessageParameters
The parameters for triggering a savepoint.
|
class |
SavepointTriggerMessageParameters
The parameters for triggering a savepoint.
|
Modifier and Type | Class and Description |
---|---|
class |
TaskManagerFileMessageParameters
Parameters for
TaskManagerCustomLogHandler . |
class |
TaskManagerMessageParameters
Message parameter for a TaskManager specific handler.
|
Modifier and Type | Class and Description |
---|---|
class |
JarDeleteMessageParameters
Message parameters for
JarDeleteHandler . |
class |
JarRunMessageParameters
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.