@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.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
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.