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<? extends 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. |
Modifier and Type | Method and Description |
---|---|
static <R extends RequestBody,M extends MessageParameters> |
HandlerRequest.create(R requestBody,
M messageParameters)
Short-cut for
HandlerRequest.create(RequestBody, MessageParameters, Collection) without any
uploaded files. |
static <R extends RequestBody,M extends MessageParameters> |
HandlerRequest.create(R requestBody,
M messageParameters,
Collection<File> uploadedFiles)
Creates a new
HandlerRequest . |
static <R extends RequestBody,M extends MessageParameters> |
HandlerRequest.resolveParametersAndCreate(R requestBody,
M messageParameters,
Map<String,String> receivedPathParameters,
Map<String,List<String>> receivedQueryParameters,
Collection<File> uploadedFiles)
Creates a new
HandlerRequest after resolving the given MessageParameters
against the given query/path parameter maps. |
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> 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> 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 |
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. |
interface |
RuntimeUntypedResponseMessageHeaders<R extends RequestBody,M extends MessageParameters>
Message headers for a web handler request that belongs to runtime module.
|
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 |
JobTaskManagerMessageParameters
Message parameters which require a job path parameter and a TaskManager id path parameter.
|
class |
JobVertexFlameGraphParameters
Message parameters for job vertex Flame Graph REST handler.
|
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
|
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 |
OperationMessageParameters
MessageParameters for operation. |
Modifier and Type | Class and Description |
---|---|
class |
SessionMessageParameters
MessagePathParameter for session handle. |
Modifier and Type | Class and Description |
---|---|
class |
FetchResultsTokenParameters
MessagePathParameter for fetch results. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.