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

Class VeniceSingleGetPath

java.lang.Object

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

com.linkedin.venice.router.api.path.VeniceSingleGetPath

All Implemented Interfaces:

ResourcePath<RouterKey>

public class VeniceSingleGetPath
extends VenicePath

Field Summary

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

retryConfig, retryManager, storeVersionName

Constructor Summary

Constructors

Constructor	Description
VeniceSingleGetPath(StoreVersionName storeVersionName, String key, String uri, VenicePartitionFinder partitionFinder, RouterStats<AggRouterHttpRequestStats> stats, RouterRetryConfig retryConfig, RetryManager retryManager, VeniceResponseDecompressor responseDecompressor)

Method Summary

Modifier and Type	Method	Description
org.apache.http.client.methods.HttpUriRequest	composeRouterRequestInternal(String storageNodeUri)
byte[]	getBody()
io.netty.handler.codec.http.HttpMethod	getHttpMethod()
String	getLocation()
int	getLongTailRetryThresholdMs()
RequestType	getRequestType()
protected RequestType	getStreamingRequestType()
String	getVeniceApiVersionHeader()
protected static boolean	isFormatB64(String key)
VenicePath	substitutePartitionKey(RouterKey s)	For single-get request, the substituted request is same as the original request.
VenicePath	substitutePartitionKey(Collection<RouterKey> s)

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

canRequestStorageNode, composeRouterRequest, getChunkedResponse, getClientComputeHeader, getHelixGroupId, getOriginalRequestStartTs, getPartitionKeys, getRequestId, getRequestSize, getResourceName, getResponseDecompressor, getSmartLongTailRetryAbortThresholdMs, getStoreName, getTime, getVersionNumber, isLongTailRetryAllowedForNewRequest, isLongTailRetryWithinBudget, isRetryRequest, isRetryRequestTooLate, isSmartLongTailRetryEnabled, isStreamingRequest, markStorageNodeAsFast, recordOriginalRequestStartTimestamp, recordRequest, requestStorageNode, setChunkedWriteHandler, setHelixGroupId, setPartitionKeys, setRetryRequest, setRetryRequest, setupRetryRelatedInfo, 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

Constructor Details

VeniceSingleGetPath

public VeniceSingleGetPath(StoreVersionName storeVersionName,
 String key,
 String uri,
 VenicePartitionFinder partitionFinder,
 RouterStats<AggRouterHttpRequestStats> stats,
 RouterRetryConfig retryConfig,
 RetryManager retryManager,
 VeniceResponseDecompressor responseDecompressor)
                    throws RouterException

Throws:

RouterException

Method Details

getRequestType

public RequestType getRequestType()

Specified by:

getRequestType in class VenicePath

getStreamingRequestType

protected RequestType getStreamingRequestType()

Overrides:

getStreamingRequestType in class VenicePath

substitutePartitionKey

public VenicePath substitutePartitionKey(RouterKey s)

For single-get request, the substituted request is same as the original request.

Specified by:

substitutePartitionKey in class VenicePath

substitutePartitionKey

public VenicePath substitutePartitionKey(@Nonnull
 Collection<RouterKey> s)

Specified by:

substitutePartitionKey in class VenicePath

composeRouterRequestInternal

public org.apache.http.client.methods.HttpUriRequest composeRouterRequestInternal(String storageNodeUri)

Specified by:

composeRouterRequestInternal in class VenicePath

getLocation

@Nonnull
public String getLocation()

isFormatB64

protected static boolean isFormatB64(String key)

getHttpMethod

public io.netty.handler.codec.http.HttpMethod getHttpMethod()

Specified by:

getHttpMethod in class VenicePath

getBody

public byte[] getBody()

Specified by:

getBody in class VenicePath

getVeniceApiVersionHeader

public String getVeniceApiVersionHeader()

Specified by:

getVeniceApiVersionHeader in class VenicePath

getLongTailRetryThresholdMs

public int getLongTailRetryThresholdMs()

Specified by:

getLongTailRetryThresholdMs in class VenicePath