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

retryManager, storeName, versionNumber

Constructor Summary

Constructors

Constructor	Description
VeniceSingleGetPath(String storeName, int versionNumber, String resourceName, String key, String uri, VenicePartitionFinder partitionFinder, RouterStats<AggRouterHttpRequestStats> stats, RetryManager retryManager)

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()
String	getPartition()
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, getHelixGroupId, getLongTailRetryThresholdMs, getOriginalRequestStartTs, getPartitionKeys, getRequestId, getRequestSize, getResourceName, getResponseDecompressor, getResponseHeaders, getSmartLongTailRetryAbortThresholdMs, getStoreName, getVersionNumber, isLongTailRetryAllowedForNewRequest, isLongTailRetryWithinBudget, isRetryRequest, isRetryRequestTooLate, isSmartLongTailRetryEnabled, isStreamingRequest, markStorageNodeAsFast, recordOriginalRequestStartTimestamp, recordRequest, requestStorageNode, setChunkedWriteHandler, setHelixGroupId, setLongTailRetryThresholdMs, setPartitionKeys, setResponseDecompressor, setResponseHeaders, 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(String storeName,
 int versionNumber,
 String resourceName,
 String key,
 String uri,
 VenicePartitionFinder partitionFinder,
 RouterStats<AggRouterHttpRequestStats> stats,
 RetryManager retryManager)
                    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)

getPartition

public String getPartition()

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