@InterfaceAudience.LimitedPrivate(value="Configuration") class ClusterStatusListener.MulticastListener extends Object implements ClusterStatusListener.Listener
Modifier and Type | Class and Description |
---|---|
private class |
ClusterStatusListener.MulticastListener.ClusterStatusHandler
Class, conforming to the Netty framework, that manages the message received.
|
Modifier and Type | Field and Description |
---|---|
private io.netty.channel.socket.DatagramChannel |
channel |
private io.netty.channel.EventLoopGroup |
group |
Constructor and Description |
---|
ClusterStatusListener.MulticastListener() |
private io.netty.channel.socket.DatagramChannel channel
private final io.netty.channel.EventLoopGroup group
public ClusterStatusListener.MulticastListener()
public void connect(org.apache.hadoop.conf.Configuration conf) throws IOException
ClusterStatusListener.Listener
connect
in interface ClusterStatusListener.Listener
conf
- Configuration to use.IOException
public void close()
ClusterStatusListener.Listener
close
in interface Closeable
close
in interface AutoCloseable
close
in interface ClusterStatusListener.Listener
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.