@InterfaceAudience.LimitedPrivate(value="Configuration") public static class ClusterStatusPublisher.MulticastPublisher extends java.lang.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 java.io.IOException
connect
in interface ClusterStatusPublisher.Publisher
java.io.IOException
public void publish(ClusterStatus cs)
publish
in interface ClusterStatusPublisher.Publisher
public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface ClusterStatusPublisher.Publisher