Package com.linkedin.venice.listener.request

Class ComputeRouterRequestWrapper

java.lang.Object

com.linkedin.venice.listener.request.RouterRequest

com.linkedin.venice.listener.request.MultiKeyRouterRequestWrapper<ComputeRouterRequestKeyV1>

com.linkedin.venice.listener.request.ComputeRouterRequestWrapper

public class ComputeRouterRequestWrapper
extends MultiKeyRouterRequestWrapper<ComputeRouterRequestKeyV1>

ComputeRouterRequestWrapper encapsulates a POST request for read-compute from routers.

Field Summary

Fields inherited from class com.linkedin.venice.listener.request.RouterRequest

NO_REQUEST_TIMEOUT

Method Summary

Modifier and Type	Method	Description
ComputeRequest	getComputeRequest()
RequestType	getRequestType()
int	getValueSchemaId()
static ComputeRouterRequestWrapper	parseComputeRequest(io.netty.handler.codec.http.FullHttpRequest httpRequest, String[] requestParts)
String	toString()

Methods inherited from class com.linkedin.venice.listener.request.MultiKeyRouterRequestWrapper

getKeyCount, getKeys

Methods inherited from class com.linkedin.venice.listener.request.RouterRequest

getResourceName, getStoreName, isRetryRequest, isStreamingRequest, setRequestTimeoutInNS, shouldRequestBeTerminatedEarly

Methods inherited from class java.lang.Object

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

Method Details

parseComputeRequest

public static ComputeRouterRequestWrapper parseComputeRequest(io.netty.handler.codec.http.FullHttpRequest httpRequest,
 String[] requestParts)

getComputeRequest

public ComputeRequest getComputeRequest()

getValueSchemaId

public int getValueSchemaId()

toString

public String toString()

Overrides:

toString in class Object

getRequestType

public RequestType getRequestType()

Specified by:

getRequestType in class RouterRequest