@InterfaceAudience.LimitedPrivate(value="Configuration") public static class ClusterStatusPublisher.MulticastPublisher extends Object implements ClusterStatusPublisher.Publisher
| Constructor and Description |
|---|
MulticastPublisher() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
connect(Configuration conf) |
void |
publish(ClusterStatus cs) |
public void connect(Configuration conf)
throws IOException
connect in interface ClusterStatusPublisher.PublisherIOExceptionpublic void publish(ClusterStatus cs)
publish in interface ClusterStatusPublisher.Publisherpublic void close()
close in interface Closeableclose in interface AutoCloseableclose in interface ClusterStatusPublisher.Publisher