public class RandomizedClusterLoadBalancerImpl extends java.lang.Object implements ClusterLoadBalancer
Constructor and Description |
---|
RandomizedClusterLoadBalancerImpl() |
Modifier and Type | Method and Description |
---|---|
Cluster |
selectCluster(@NonNull @NotEmpty java.util.Set<Cluster> clusters,
@NonNull JobRequest jobRequest)
Return best cluster to run job on.
|
public Cluster selectCluster(@Nonnull @NonNull @NotEmpty @NonNull @NotEmpty java.util.Set<Cluster> clusters, @Nonnull @NonNull @NonNull JobRequest jobRequest) throws GenieException
selectCluster
in interface ClusterLoadBalancer
clusters
- An immutable, non-empty list of available clusters to choose fromjobRequest
- The job request these clusters are being load balanced forGenieException
- if there is any error