@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.Publisher
IOException
public void publish(ClusterStatus cs)
publish
in interface ClusterStatusPublisher.Publisher
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface ClusterStatusPublisher.Publisher