public class HandlerRedirectUtils extends Object
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.
Constructor and Description |
---|
HandlerRedirectUtils() |
Modifier and Type | Method and Description |
---|---|
static String |
getRedirectAddress(String localJobManagerAddress,
scala.Tuple2<ActorGateway,Integer> leader) |
static io.netty.handler.codec.http.HttpResponse |
getRedirectResponse(String redirectAddress,
String path,
boolean httpsEnabled) |
static io.netty.handler.codec.http.HttpResponse |
getUnavailableResponse() |
public static String getRedirectAddress(String localJobManagerAddress, scala.Tuple2<ActorGateway,Integer> leader) throws Exception
Exception
public static io.netty.handler.codec.http.HttpResponse getRedirectResponse(String redirectAddress, String path, boolean httpsEnabled) throws Exception
Exception
public static io.netty.handler.codec.http.HttpResponse getUnavailableResponse()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.