Package com.linkedin.venice.fastclient.meta

Class HelixLeastLoadedGroupRoutingStrategy

java.lang.Object

com.linkedin.venice.fastclient.meta.AbstractClientRoutingStrategy

com.linkedin.venice.fastclient.meta.HelixGroupRoutingStrategy

com.linkedin.venice.fastclient.meta.HelixLeastLoadedGroupRoutingStrategy

public class HelixLeastLoadedGroupRoutingStrategy
extends HelixGroupRoutingStrategy

This class is used to route requests to the least loaded group based on the response time collected in the past. So far, it only tracks the response time of multi-key requests.

Field Summary

Fields inherited from class com.linkedin.venice.fastclient.meta.HelixGroupRoutingStrategy

helixGroupInfoAtomicReference, helixGroupStats, instanceHealthMonitor

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
int	getHelixGroupId(long requestId, int groupIdForOriginalRequest)	Get the least loaded group based on the response time collected in the past.

Methods inherited from class com.linkedin.venice.fastclient.meta.HelixGroupRoutingStrategy

getGroupCount, getReplicas, trackRequest, updateHelixGroupInfo

Methods inherited from class java.lang.Object

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

Constructor Details

HelixLeastLoadedGroupRoutingStrategy

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

Method Details

getHelixGroupId

public int getHelixGroupId(long requestId,
 int groupIdForOriginalRequest)

Get the least loaded group based on the response time collected in the past.

Overrides:

getHelixGroupId in class HelixGroupRoutingStrategy