Modifier and Type | Method and Description |
---|---|
<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. |
class |
HandlerRequest<R extends RequestBody,M extends MessageParameters>
Simple container for the request to a handler, that contains the
RequestBody and path/query parameters. |
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 | 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 |
EmptyMessageParameters
MessageParameters implementation which has no parameters.
|
class |
JobMessageParameters
Message parameters which require a job path parameter.
|
class |
JobTerminationMessageParameters
Parameters for job related REST handlers.
|
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 |
SavepointMessageParameters
The parameters for triggering a savepoint.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.