public class ClusterStatusPublisher
extends ScheduledChore
Modifier and Type | Class and Description |
---|---|
static class |
ClusterStatusPublisher.MulticastPublisher |
static interface |
ClusterStatusPublisher.Publisher |
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_STATUS_PUBLISH_PERIOD |
static java.lang.Class<? extends ClusterStatusPublisher.Publisher> |
DEFAULT_STATUS_PUBLISHER_CLASS |
static int |
MAX_SERVER_PER_MESSAGE
We want to limit the size of the protobuf message sent, do fit into a single packet.
|
static int |
NB_SEND
If a server dies, we're sending the information multiple times in case a receiver misses the
message.
|
static java.lang.String |
STATUS_PUBLISH_PERIOD
The minimum time between two status messages, in milliseconds.
|
static java.lang.String |
STATUS_PUBLISHER_CLASS
The implementation class used to publish the status.
|
Modifier | Constructor and Description |
---|---|
protected |
ClusterStatusPublisher() |
|
ClusterStatusPublisher(HMaster master,
Configuration conf,
java.lang.Class<? extends ClusterStatusPublisher.Publisher> publisherClass) |
Modifier and Type | Method and Description |
---|---|
protected void |
chore() |
protected void |
cleanup() |
protected java.util.List<ServerName> |
generateDeadServersListToSend()
Create the dead server to send.
|
protected java.util.List<<any>> |
getDeadServers(long since)
Get the servers which died since a given timestamp.
|
public static final java.lang.String STATUS_PUBLISHER_CLASS
public static final java.lang.Class<? extends ClusterStatusPublisher.Publisher> DEFAULT_STATUS_PUBLISHER_CLASS
public static final java.lang.String STATUS_PUBLISH_PERIOD
public static final int DEFAULT_STATUS_PUBLISH_PERIOD
public static final int MAX_SERVER_PER_MESSAGE
public static final int NB_SEND
public ClusterStatusPublisher(HMaster master, Configuration conf, java.lang.Class<? extends ClusterStatusPublisher.Publisher> publisherClass) throws java.io.IOException
java.io.IOException
protected ClusterStatusPublisher()
protected void chore()
protected void cleanup()
protected java.util.List<ServerName> generateDeadServersListToSend()
protected java.util.List<<any>> getDeadServers(long since)