io.druid.server.coordinator

Class DruidCluster

java.lang.Object

io.druid.server.coordinator.DruidCluster

public class DruidCluster
extends Object

Contains a representation of the current state of the cluster by tier. Each tier is mapped to the list of servers for that tier sorted by available space.

Constructor Summary

Constructors

Constructor and Description
DruidCluster()
DruidCluster(Map<String,com.google.common.collect.MinMaxPriorityQueue<ServerHolder>> cluster)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(ServerHolder serverHolder)
com.google.common.collect.MinMaxPriorityQueue<ServerHolder>	get(String tier)
Map<String,com.google.common.collect.MinMaxPriorityQueue<ServerHolder>>	getCluster()
com.google.common.collect.MinMaxPriorityQueue<ServerHolder>	getServersByTier(String tier)
Iterable<com.google.common.collect.MinMaxPriorityQueue<ServerHolder>>	getSortedServersByTier()
Iterable<String>	getTierNames()
boolean	hasTier(String tier)
boolean	isEmpty()

Methods inherited from class java.lang.Object

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

Constructor Detail

DruidCluster

public DruidCluster()

DruidCluster

public DruidCluster(Map<String,com.google.common.collect.MinMaxPriorityQueue<ServerHolder>> cluster)

Method Detail

add

public void add(ServerHolder serverHolder)

getCluster

public Map<String,com.google.common.collect.MinMaxPriorityQueue<ServerHolder>> getCluster()

getTierNames

public Iterable<String> getTierNames()

getServersByTier

public com.google.common.collect.MinMaxPriorityQueue<ServerHolder> getServersByTier(String tier)

getSortedServersByTier

public Iterable<com.google.common.collect.MinMaxPriorityQueue<ServerHolder>> getSortedServersByTier()

isEmpty

public boolean isEmpty()

hasTier

public boolean hasTier(String tier)

get

public com.google.common.collect.MinMaxPriorityQueue<ServerHolder> get(String tier)