Package com.linkedin.venice.fastclient

Class MultiKeyRequestContext<K,V>

java.lang.Object

com.linkedin.venice.fastclient.RequestContext

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

Type Parameters:

K - Key type

V - Value type

Direct Known Subclasses:

BatchGetRequestContext, ComputeRequestContext

public abstract class MultiKeyRequestContext<K,V>
extends RequestContext

Keep track of the progress of a multi-key requests - batch get and compute. This includes tracking all the scatter requests and utilities to gather responses.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MultiKeyRequestContext.KeyInfo<K>	represents a key requested on a route and tracks info related to it but specific to the route

Method Summary

Modifier and Type	Method	Description
int	getFanoutSize()
java.util.Map<java.lang.Integer,java.util.Set<java.lang.String>>	getRoutesForPartitionMapping()
void	setFanoutSize(int fanoutSize)
void	setRoutesForPartitionMapping(java.util.Map<java.lang.Integer,java.util.Set<java.lang.String>> routesForPartition)

Methods inherited from class com.linkedin.venice.fastclient.RequestContext

getRequestType

Methods inherited from class java.lang.Object

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

Method Detail

getRoutesForPartitionMapping

public java.util.Map<java.lang.Integer,java.util.Set<java.lang.String>> getRoutesForPartitionMapping()

setRoutesForPartitionMapping

public void setRoutesForPartitionMapping(java.util.Map<java.lang.Integer,java.util.Set<java.lang.String>> routesForPartition)

setFanoutSize

public void setFanoutSize(int fanoutSize)

getFanoutSize

public int getFanoutSize()