ComputeRequestContext (venice API)

java.lang.Object

com.linkedin.venice.fastclient.RequestContext

com.linkedin.venice.fastclient.MultiKeyRequestContext<K,V>

com.linkedin.venice.fastclient.ComputeRequestContext<K,V>

Type Parameters:: K - Key type; V - Value type

public class ComputeRequestContext<K,V> extends MultiKeyRequestContext<K,V>

Keep track of the progress of a compute request . This includes tracking all the scatter requests and utilities to gather responses.

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.venice.fastclient.MultiKeyRequestContext
MultiKeyRequestContext.KeyInfo<K>
Constructor Summary

Constructors

Constructor

Description

ComputeRequestContext(int numKeysInRequest, boolean isPartialSuccessAllowed)
Method Summary

Modifier and Type

Method

Description

ComputeRequestContext<K,V>

createRetryRequestContext(int numKeysInRequest)

RequestType

getRequestType()

Methods inherited from class com.linkedin.venice.fastclient.MultiKeyRequestContext
addKey, copyStateToRetryRequestContext, getFanoutSize, getKeys, getRoutes, getRoutesForPartitionMapping, setFanoutSize, setKeys, setRoutesForPartitionMapping

Methods inherited from class com.linkedin.venice.fastclient.RequestContext
addNonAvailableReplicaPartition, getCurrentVersion, getHelixGroupId, getInstanceHealthMonitor, getNonAvailableReplicaPartitions, getRequestId, getResultFuture, getRouteRequestMap, getServerClusterName, hasNonAvailablePartition, isRetryRequest, setCurrentVersion, setHelixGroupId, setInstanceHealthMonitor, setRequestId, setRequestSerializationTime, setResultFuture, setRetryRequest, setServerClusterName

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- ComputeRequestContext
  
  public ComputeRequestContext(int numKeysInRequest, boolean isPartialSuccessAllowed)
Method Details
- getRequestType
  
  public RequestType getRequestType()
  
  Specified by:
  
  getRequestType in class RequestContext
- createRetryRequestContext
  
  public ComputeRequestContext<K,V> createRetryRequestContext(int numKeysInRequest)