Package com.linkedin.venice.fastclient.meta

Class HelixGroupRoutingStrategy

java.lang.Object

com.linkedin.venice.fastclient.meta.AbstractClientRoutingStrategy

com.linkedin.venice.fastclient.meta.HelixGroupRoutingStrategy

Direct Known Subclasses:

HelixLeastLoadedGroupRoutingStrategy

public class HelixGroupRoutingStrategy
extends AbstractClientRoutingStrategy

This strategy will assign an ordering of helix groups via round-robin for even distribution. The fanout in multi-get will be performed using instances belonging to the assigned groups. If no instance belonging to the selected group is found for a given partition, the instance with the next group in the assigned ordering will be used

Field Summary

Fields

Modifier and Type	Field	Description
protected AtomicReference<HelixGroupInfo>	helixGroupInfoAtomicReference
protected final HelixGroupStats	helixGroupStats
protected final InstanceHealthMonitor	instanceHealthMonitor

Constructor Summary

Constructors

Constructor	Description
HelixGroupRoutingStrategy(InstanceHealthMonitor instanceHealthMonitor, io.tehuti.metrics.MetricsRepository metricsRepository, String storeName)

Method Summary

Modifier and Type	Method	Description
int	getGroupCount()
int	getHelixGroupId(long requestId, int groupIdForOriginalRequest)
String	getReplicas(long requestId, int groupId, List<String> replicas)
boolean	trackRequest(RequestContext requestContext)	This method is used to track the request for any custom logic that needs to be executed when a request is sent.
void	updateHelixGroupInfo(Map<String,Integer> instanceToHelixGroupIdMap)

Methods inherited from class java.lang.Object

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

Field Details

helixGroupInfoAtomicReference

protected AtomicReference<HelixGroupInfo> helixGroupInfoAtomicReference

instanceHealthMonitor

protected final InstanceHealthMonitor instanceHealthMonitor

helixGroupStats

protected final HelixGroupStats helixGroupStats

Constructor Details

HelixGroupRoutingStrategy

public HelixGroupRoutingStrategy(InstanceHealthMonitor instanceHealthMonitor,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 String storeName)

Method Details

getReplicas

public String getReplicas(long requestId,
 int groupId,
 List<String> replicas)

Overrides:

getReplicas in class AbstractClientRoutingStrategy

getGroupCount

public int getGroupCount()

updateHelixGroupInfo

public void updateHelixGroupInfo(Map<String,Integer> instanceToHelixGroupIdMap)

Overrides:

updateHelixGroupInfo in class AbstractClientRoutingStrategy

getHelixGroupId

public int getHelixGroupId(long requestId,
 int groupIdForOriginalRequest)

Overrides:

getHelixGroupId in class AbstractClientRoutingStrategy

trackRequest

public boolean trackRequest(RequestContext requestContext)

Description copied from class: AbstractClientRoutingStrategy

This method is used to track the request for any custom logic that needs to be executed when a request is sent.

Overrides:

trackRequest in class AbstractClientRoutingStrategy

Returns:

boolean to indicate whether the request is tracked or not.