org.apache.flink.runtime.rest.handler.util

Class HandlerRedirectUtils

java.lang.Object

org.apache.flink.runtime.rest.handler.util.HandlerRedirectUtils

public class HandlerRedirectUtils
extends Object

Utilities to extract a redirect address.

This is necessary at the moment, because many execution graph structures are not serializable. The proper solution here is to have these serializable and transparently work with the leading job manager instead of redirecting.

Field Summary

Fields

Modifier and Type	Field and Description
static Charset	ENCODING

Constructor Summary

Constructors

Constructor and Description
HandlerRedirectUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponse	getErrorResponse(Throwable throwable)
static org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponse	getErrorResponse(Throwable throwable, org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseStatus status)
static CompletableFuture<Optional<String>>	getRedirectAddress(String localRestAddress, RestfulGateway restfulGateway, Time timeout)
static org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponse	getRedirectResponse(String redirectAddress, String path)
static org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponse	getRedirectResponse(String redirectAddress, String path, org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseStatus code)
static org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponse	getResponse(org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseStatus status, String message)
static org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponse	getUnavailableResponse()

Methods inherited from class java.lang.Object

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

Field Detail

ENCODING

public static final Charset ENCODING

Constructor Detail

HandlerRedirectUtils

public HandlerRedirectUtils()

Method Detail

getRedirectAddress

public static CompletableFuture<Optional<String>> getRedirectAddress(String localRestAddress,
                                                                     RestfulGateway restfulGateway,
                                                                     Time timeout)

getRedirectResponse

public static org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponse getRedirectResponse(String redirectAddress,
                                                                                                          String path)

getRedirectResponse

public static org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponse getRedirectResponse(String redirectAddress,
                                                                                                          String path,
                                                                                                          org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseStatus code)

getUnavailableResponse

public static org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponse getUnavailableResponse()

getResponse

public static org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponse getResponse(org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseStatus status,
                                                                                                  @Nullable
                                                                                                  String message)

getErrorResponse

public static org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponse getErrorResponse(Throwable throwable)

getErrorResponse

public static org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponse getErrorResponse(Throwable throwable,
                                                                                                       org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseStatus status)