Toggle navigation
Home
org.apache.flink.shaded.netty4.io.netty.handler.codec.http.router.Routed to org.apache.flink.runtime.rest.handler.router.RoutedRequest
No. of Instances - 10
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
routed.request()
to
request
routed.path()
to
routedRequest
optLeaderConsumer.ifPresent(gateway -> { CompletableFuture<Optional<String>> optRedirectAddressFuture=HandlerRedirectUtils.getRedirectAddress(localAddress,gateway,timeout); ReferenceCountUtil.retain(routed); optRedirectAddressFuture.whenCompleteAsync(( Optional<String> optRedirectAddress, Throwable throwable) -> { HttpResponse response; try { if (throwable != null) { logger.error("Could not retrieve the redirect address.",throwable); HandlerUtils.sendErrorResponse(channelHandlerContext,request,new ErrorResponseBody("Could not retrieve the redirect address of the current leader. Please try to refresh."),HttpResponseStatus.INTERNAL_SERVER_ERROR,responseHeaders); } else if (optRedirectAddress.isPresent()) { response=HandlerRedirectUtils.getRedirectResponse(optRedirectAddress.get(),routedRequest); KeepAliveWrite.flush(channelHandlerContext,request,response); } else { try { respondAsLeader(channelHandlerContext,routed,gateway); } catch ( Exception e) { logger.error("Error while responding as leader.",e); HandlerUtils.sendErrorResponse(channelHandlerContext,request,new ErrorResponseBody("Error while responding to the request."),HttpResponseStatus.INTERNAL_SERVER_ERROR,responseHeaders); } } } finally { ReferenceCountUtil.release(routed); } } ,channelHandlerContext.executor()); } )
to
optLeaderConsumer.ifPresent(gateway -> { CompletableFuture<Optional<String>> optRedirectAddressFuture=HandlerRedirectUtils.getRedirectAddress(localAddress,gateway,timeout); ReferenceCountUtil.retain(routedRequest); optRedirectAddressFuture.whenCompleteAsync(( Optional<String> optRedirectAddress, Throwable throwable) -> { HttpResponse response; try { if (throwable != null) { logger.error("Could not retrieve the redirect address.",throwable); HandlerUtils.sendErrorResponse(channelHandlerContext,request,new ErrorResponseBody("Could not retrieve the redirect address of the current leader. Please try to refresh."),HttpResponseStatus.INTERNAL_SERVER_ERROR,responseHeaders); } else if (optRedirectAddress.isPresent()) { response=HandlerRedirectUtils.getRedirectResponse(optRedirectAddress.get(),routedRequest.getPath()); KeepAliveWrite.flush(channelHandlerContext,request,response); } else { try { respondAsLeader(channelHandlerContext,routedRequest,gateway); } catch ( Exception e) { logger.error("Error while responding as leader.",e); HandlerUtils.sendErrorResponse(channelHandlerContext,request,new ErrorResponseBody("Error while responding to the request."),HttpResponseStatus.INTERNAL_SERVER_ERROR,responseHeaders); } } } finally { ReferenceCountUtil.release(routedRequest); } } ,channelHandlerContext.executor()); } )
routed.request()
to
routed.getRequest()
routed
to
routedRequest.getRouteResult()
routed.request()
to
routedRequest.getRequest()
routed.path()
to
routedRequest.getPath()
routed.path()
to
routedRequest.getPath()
routed.path()
to
routedRequest.getPath()
routed
to
routedRequest.getPath()
routed.path()
to
routedRequest
routed
to
routedRequest.getPath()
routed.path()
to
routedRequest
routed
to
routedRequest.getRequest()
routed.request()
to
routedRequest
Rename Variable
routed
to
routedRequest
routed
to
routedRequest
routed
to
routedRequest
routed
to
routedRequest
routed
to
routedRequest
routed
to
routedRequest
routed
to
routedRequest
routed
to
routedRequest
routed
to
routedRequest
Cascading Type Change (Different)
HttpHeaders.Names
to
Names