org.apache.flink.runtime.rest

Class RestClient

java.lang.Object

org.apache.flink.runtime.rest.RestClient

public class RestClient
extends Object

This client is the counter-part to the RestServerEndpoint.

Constructor Summary

Constructors

Constructor and Description
RestClient(RestClientConfiguration configuration, Executor executor)

Method Summary

Modifier and Type	Method and Description
<M extends MessageHeaders<EmptyRequestBody,P,EmptyMessageParameters>,P extends ResponseBody> CompletableFuture<P>	sendRequest(String targetAddress, int targetPort, M messageHeaders)
<M extends MessageHeaders<R,P,EmptyMessageParameters>,R extends RequestBody,P extends ResponseBody> CompletableFuture<P>	sendRequest(String targetAddress, int targetPort, M messageHeaders, R request)
<M extends MessageHeaders<EmptyRequestBody,P,U>,U extends MessageParameters,P extends ResponseBody> CompletableFuture<P>	sendRequest(String targetAddress, int targetPort, M messageHeaders, U messageParameters)
<M extends MessageHeaders<R,P,U>,U extends MessageParameters,R extends RequestBody,P extends ResponseBody> CompletableFuture<P>	sendRequest(String targetAddress, int targetPort, M messageHeaders, U messageParameters, R request)
void	shutdown(Time timeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RestClient

public RestClient(RestClientConfiguration configuration,
                  Executor executor)

Method Detail

shutdown

public void shutdown(Time timeout)

sendRequest

public <M extends MessageHeaders<EmptyRequestBody,P,U>,U extends MessageParameters,P extends ResponseBody> CompletableFuture<P> sendRequest(String targetAddress,
                                                                                                                                            int targetPort,
                                                                                                                                            M messageHeaders,
                                                                                                                                            U messageParameters)
                                                                                                                                     throws IOException

Throws:

IOException

sendRequest

public <M extends MessageHeaders<R,P,EmptyMessageParameters>,R extends RequestBody,P extends ResponseBody> CompletableFuture<P> sendRequest(String targetAddress,
                                                                                                                                            int targetPort,
                                                                                                                                            M messageHeaders,
                                                                                                                                            R request)
                                                                                                                                     throws IOException

Throws:

IOException

sendRequest

public <M extends MessageHeaders<EmptyRequestBody,P,EmptyMessageParameters>,P extends ResponseBody> CompletableFuture<P> sendRequest(String targetAddress,
                                                                                                                                     int targetPort,
                                                                                                                                     M messageHeaders)
                                                                                                                              throws IOException

Throws:

IOException

sendRequest

public <M extends MessageHeaders<R,P,U>,U extends MessageParameters,R extends RequestBody,P extends ResponseBody> CompletableFuture<P> sendRequest(String targetAddress,
                                                                                                                                                   int targetPort,
                                                                                                                                                   M messageHeaders,
                                                                                                                                                   U messageParameters,
                                                                                                                                                   R request)
                                                                                                                                            throws IOException

Throws:

IOException