public class JobVertexAccumulatorsHeaders extends Object implements MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters>
JobVertexAccumulatorsHandler
.Modifier and Type | Method and Description |
---|---|
HttpMethodWrapper |
getHttpMethod()
Returns the
HttpMethodWrapper to be used for the request. |
static JobVertexAccumulatorsHeaders |
getInstance() |
Class<EmptyRequestBody> |
getRequestClass()
Returns the class of the request message.
|
Class<JobVertexAccumulatorsInfo> |
getResponseClass()
Returns the class of the response message.
|
org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseStatus |
getResponseStatusCode()
Returns the http status code for the response.
|
String |
getTargetRestEndpointURL()
Returns the generalized endpoint url that this request should be sent to, for example
/job/:jobid . |
JobVertexMessageParameters |
getUnresolvedMessageParameters()
Returns a new
MessageParameters object. |
public static final String URL
public Class<EmptyRequestBody> getRequestClass()
MessageHeaders
getRequestClass
in interface MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters>
public Class<JobVertexAccumulatorsInfo> getResponseClass()
MessageHeaders
getResponseClass
in interface MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters>
public org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseStatus getResponseStatusCode()
MessageHeaders
getResponseStatusCode
in interface MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters>
public JobVertexMessageParameters getUnresolvedMessageParameters()
MessageHeaders
MessageParameters
object.getUnresolvedMessageParameters
in interface MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters>
public HttpMethodWrapper getHttpMethod()
RestHandlerSpecification
HttpMethodWrapper
to be used for the request.getHttpMethod
in interface RestHandlerSpecification
public String getTargetRestEndpointURL()
RestHandlerSpecification
/job/:jobid
.getTargetRestEndpointURL
in interface RestHandlerSpecification
public static JobVertexAccumulatorsHeaders getInstance()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.