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(Set<ServerHolder> realtimes, Map<String,NavigableSet<ServerHolder>> historicals)

Method Summary

Modifier and Type	Method and Description
void	add(ServerHolder serverHolder)
Collection<ServerHolder>	getAllServers()
Map<String,NavigableSet<ServerHolder>>	getHistoricals()
NavigableSet<ServerHolder>	getHistoricalsByTier(String tier)
Set<ServerHolder>	getRealtimes()
Iterable<NavigableSet<ServerHolder>>	getSortedHistoricalsByTier()
Iterable<String>	getTierNames()
boolean	hasHistoricals()
boolean	hasRealtimes()
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(@Nullable
                    Set<ServerHolder> realtimes,
                    Map<String,NavigableSet<ServerHolder>> historicals)

Method Detail

add

public void add(ServerHolder serverHolder)

getRealtimes

public Set<ServerHolder> getRealtimes()

getHistoricals

public Map<String,NavigableSet<ServerHolder>> getHistoricals()

getTierNames

public Iterable<String> getTierNames()

getHistoricalsByTier

public NavigableSet<ServerHolder> getHistoricalsByTier(String tier)

getAllServers

public Collection<ServerHolder> getAllServers()

getSortedHistoricalsByTier

public Iterable<NavigableSet<ServerHolder>> getSortedHistoricalsByTier()

isEmpty

public boolean isEmpty()

hasHistoricals

public boolean hasHistoricals()

hasRealtimes

public boolean hasRealtimes()

hasTier

public boolean hasTier(String tier)