Package com.linkedin.venice.router.api.path

Class VeniceComputePath

java.lang.Object

com.linkedin.venice.router.api.path.VenicePath

com.linkedin.venice.router.api.path.VeniceMultiKeyPath<ComputeRouterRequestKeyV1>

com.linkedin.venice.router.api.path.VeniceComputePath

All Implemented Interfaces:

ResourcePath<RouterKey>

public class VeniceComputePath
extends VeniceMultiKeyPath<ComputeRouterRequestKeyV1>

Field Summary

Fields inherited from class com.linkedin.venice.router.api.path.VeniceMultiKeyPath

routerKeyMap

Fields inherited from class com.linkedin.venice.router.api.path.VenicePath

retryConfig, retryManager, storeVersionName

Constructor Summary

Constructors

Constructor	Description
VeniceComputePath(StoreVersionName storeVersionName, BasicFullHttpRequest request, VenicePartitionFinder partitionFinder, int maxKeyCount, AggRouterHttpRequestStats stats, RouterRetryConfig retryConfig, RetryManager retryManager, VeniceResponseDecompressor responseDecompressor)

Method Summary

Modifier and Type	Method	Description
protected ComputeRouterRequestKeyV1	createRouterRequestKey(ByteBuffer key, int keyIdx, int partitionId)	Create a router request key.
protected VeniceComputePath	fixRetryRequestForSubPath(Map<RouterKey,ComputeRouterRequestKeyV1> routerKeyMap)	If the parent request is a retry request, the sub-request generated by scattering-gathering logic should be retry request as well.
protected int	getComputeRequestLengthInBytes()
String	getLocation()
final RequestType	getRequestType()
final RequestType	getStreamingRequestType()
String	getVeniceApiVersionHeader()
protected byte[]	serializeRouterRequest()	For multi-get requests, simply serialize the set of RouterKey to bytes; for read compute requests, concatenate the compute request and the serialized keys
void	setupVeniceHeaders(BiConsumer<String,String> setupHeaderFunc)
VeniceMultiGetPath	toMultiGetPath()

Methods inherited from class com.linkedin.venice.router.api.path.VeniceMultiKeyPath

composeRouterRequestInternal, getBody, getChunkedResponse, getHelixGroupId, getHttpMethod, getLongTailRetryMaxRouteForMultiKeyReq, getLongTailRetryThresholdMs, getRequestId, getSmartLongTailRetryAbortThresholdMs, initialize, isLongTailRetryAllowedForNewRequest, isSmartLongTailRetryEnabled, setChunkedWriteHandler, setHelixGroupId, setupRetryRelatedInfo, substitutePartitionKey, substitutePartitionKey

Methods inherited from class com.linkedin.venice.router.api.path.VenicePath

canRequestStorageNode, composeRouterRequest, getClientComputeHeader, getOriginalRequestStartTs, getPartitionKeys, getRequestSize, getResourceName, getResponseDecompressor, getStoreName, getTime, getVersionNumber, isLongTailRetryWithinBudget, isRetryRequest, isRetryRequestTooLate, isStreamingRequest, markStorageNodeAsFast, recordOriginalRequestStartTimestamp, recordRequest, requestStorageNode, setPartitionKeys, setRetryRequest, setRetryRequest

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.alpini.router.api.ResourcePath

getPartitionKey

Constructor Details

VeniceComputePath

public VeniceComputePath(StoreVersionName storeVersionName,
 BasicFullHttpRequest request,
 VenicePartitionFinder partitionFinder,
 int maxKeyCount,
 AggRouterHttpRequestStats stats,
 RouterRetryConfig retryConfig,
 RetryManager retryManager,
 VeniceResponseDecompressor responseDecompressor)
                  throws RouterException

Throws:

RouterException

Method Details

getLocation

@Nonnull
public String getLocation()

getRequestType

public final RequestType getRequestType()

Specified by:

getRequestType in class VenicePath

getStreamingRequestType

public final RequestType getStreamingRequestType()

Overrides:

getStreamingRequestType in class VenicePath

toMultiGetPath

public VeniceMultiGetPath toMultiGetPath()

fixRetryRequestForSubPath

protected VeniceComputePath fixRetryRequestForSubPath(Map<RouterKey,ComputeRouterRequestKeyV1> routerKeyMap)

If the parent request is a retry request, the sub-request generated by scattering-gathering logic should be retry request as well.

Specified by:

fixRetryRequestForSubPath in class VeniceMultiKeyPath<ComputeRouterRequestKeyV1>

Parameters:

routerKeyMap -

Returns:

createRouterRequestKey

protected ComputeRouterRequestKeyV1 createRouterRequestKey(ByteBuffer key,
 int keyIdx,
 int partitionId)

Description copied from class: VeniceMultiKeyPath

Create a router request key.

Specified by:

createRouterRequestKey in class VeniceMultiKeyPath<ComputeRouterRequestKeyV1>

Returns:

An instance of ComputeRouterRequestKeyV1 for compute request; return an instance of MultiGetRouterRequestKeyV1 for multi-get

serializeRouterRequest

protected byte[] serializeRouterRequest()

Description copied from class: VeniceMultiKeyPath

For multi-get requests, simply serialize the set of RouterKey to bytes; for read compute requests, concatenate the compute request and the serialized keys

Specified by:

serializeRouterRequest in class VeniceMultiKeyPath<ComputeRouterRequestKeyV1>

Returns:

setupVeniceHeaders

public void setupVeniceHeaders(BiConsumer<String,String> setupHeaderFunc)

Overrides:

setupVeniceHeaders in class VenicePath

getVeniceApiVersionHeader

public String getVeniceApiVersionHeader()

Specified by:

getVeniceApiVersionHeader in class VenicePath

getComputeRequestLengthInBytes

protected int getComputeRequestLengthInBytes()