org.apache.hadoop.hbase.client

Class ClusterStatusListener.MulticastListener

java.lang.Object

org.apache.hadoop.hbase.client.ClusterStatusListener.MulticastListener

All Implemented Interfaces:

Closeable, AutoCloseable, ClusterStatusListener.Listener

Enclosing class:

ClusterStatusListener

@InterfaceAudience.LimitedPrivate(value="Configuration")
class ClusterStatusListener.MulticastListener
extends Object
implements ClusterStatusListener.Listener

An implementation using a multicast message between the master & the client.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	ClusterStatusListener.MulticastListener.ClusterStatusHandler Class, conforming to the Netty framework, that manages the message received.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hbase.thirdparty.io.netty.channel.socket.DatagramChannel	channel
private org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup	group

Constructor Summary

Constructors

Constructor and Description
MulticastListener()

Method Summary

Modifier and Type	Method and Description
void	close() Called to close the resources, if any.
void	connect(org.apache.hadoop.conf.Configuration conf) Called to connect.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

channel

private org.apache.hbase.thirdparty.io.netty.channel.socket.DatagramChannel channel

group

private final org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup group

Constructor Detail

MulticastListener

public MulticastListener()

Method Detail

connect

public void connect(org.apache.hadoop.conf.Configuration conf)
             throws IOException

Description copied from interface: ClusterStatusListener.Listener

Called to connect.

Specified by:

connect in interface ClusterStatusListener.Listener

Parameters:

conf - Configuration to use.

Throws:

IOException - if failing to connect

close

public void close()

Description copied from interface: ClusterStatusListener.Listener

Called to close the resources, if any. Cannot throw an exception.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ClusterStatusListener.Listener