@InterfaceAudience.LimitedPrivate(value="Configuration") public static class ClusterStatusPublisher.MulticastPublisher extends Object implements ClusterStatusPublisher.Publisher
| Modifier and Type | Class and Description |
|---|---|
private static class |
ClusterStatusPublisher.MulticastPublisher.ClusterStatusEncoder |
private static class |
ClusterStatusPublisher.MulticastPublisher.HBaseDatagramChannelFactory<T extends io.netty.channel.Channel> |
| Modifier and Type | Field and Description |
|---|---|
private io.netty.channel.socket.DatagramChannel |
channel |
private io.netty.channel.EventLoopGroup |
group |
| Constructor and Description |
|---|
ClusterStatusPublisher.MulticastPublisher() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
connect(org.apache.hadoop.conf.Configuration conf) |
void |
publish(ClusterStatus cs) |
private io.netty.channel.socket.DatagramChannel channel
private final io.netty.channel.EventLoopGroup group
public ClusterStatusPublisher.MulticastPublisher()
public void connect(org.apache.hadoop.conf.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.PublisherCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.