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

Class VeniceMultiGetPath

java.lang.Object

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

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

com.linkedin.venice.router.api.path.VeniceMultiGetPath

All Implemented Interfaces:

ResourcePath<RouterKey>

public class VeniceMultiGetPath
extends VeniceMultiKeyPath<MultiGetRouterRequestKeyV1>

Field Summary

Fields

Modifier and Type	Field	Description
protected static final ReadAvroProtocolDefinition	EXPECTED_PROTOCOL

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
VeniceMultiGetPath(StoreVersionName storeVersionName, BasicFullHttpRequest request, VenicePartitionFinder partitionFinder, int maxKeyCount, AggRouterHttpRequestStats stats, RouterRetryConfig retryConfig, RetryManager retryManager, VeniceResponseDecompressor responseDecompressor, String clientComputeHeader)

Method Summary

Modifier and Type	Method	Description
protected MultiGetRouterRequestKeyV1	createRouterRequestKey(ByteBuffer key, int keyIdx, int partitionId)	Create a router request key.
protected VeniceMultiGetPath	fixRetryRequestForSubPath(Map<RouterKey,MultiGetRouterRequestKeyV1> routerKeyMap)	If the parent request is a retry request, the sub-request generated by scattering-gathering logic should be retry request as well.
String	getClientComputeHeader()
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

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, getOriginalRequestStartTs, getPartitionKeys, getRequestSize, getResourceName, getResponseDecompressor, getStoreName, getTime, getVersionNumber, isLongTailRetryWithinBudget, isRetryRequest, isRetryRequestTooLate, isStreamingRequest, markStorageNodeAsFast, recordOriginalRequestStartTimestamp, recordRequest, requestStorageNode, setPartitionKeys, setRetryRequest, setRetryRequest, setupVeniceHeaders

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

Field Details

EXPECTED_PROTOCOL

protected static final ReadAvroProtocolDefinition EXPECTED_PROTOCOL

Constructor Details

VeniceMultiGetPath

public VeniceMultiGetPath(StoreVersionName storeVersionName,
 BasicFullHttpRequest request,
 VenicePartitionFinder partitionFinder,
 int maxKeyCount,
 AggRouterHttpRequestStats stats,
 RouterRetryConfig retryConfig,
 RetryManager retryManager,
 VeniceResponseDecompressor responseDecompressor,
 String clientComputeHeader)
                   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

fixRetryRequestForSubPath

protected VeniceMultiGetPath fixRetryRequestForSubPath(Map<RouterKey,MultiGetRouterRequestKeyV1> 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<MultiGetRouterRequestKeyV1>

Parameters:

routerKeyMap -

Returns:

createRouterRequestKey

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

Description copied from class: VeniceMultiKeyPath

Create a router request key.

Specified by:

createRouterRequestKey in class VeniceMultiKeyPath<MultiGetRouterRequestKeyV1>

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<MultiGetRouterRequestKeyV1>

Returns:

getVeniceApiVersionHeader

public String getVeniceApiVersionHeader()

Specified by:

getVeniceApiVersionHeader in class VenicePath

getClientComputeHeader

@Nullable
public String getClientComputeHeader()

Overrides:

getClientComputeHeader in class VenicePath