org.apache.hadoop.hbase.ipc

Class NettyRpcClientConfigHelper

java.lang.Object

org.apache.hadoop.hbase.ipc.NettyRpcClientConfigHelper

@InterfaceAudience.Public
public class NettyRpcClientConfigHelper
extends Object

Helper class for passing config to NettyRpcClient.

As hadoop Configuration can not pass an Object directly, we need to find a way to pass the EventLoopGroup to AsyncRpcClient if we want to use a single EventLoopGroup for the whole process.

Since:

2.0.0

Field Summary

Fields

Modifier and Type	Field and Description
static String	EVENT_LOOP_CONFIG

Constructor Summary

Constructors

Constructor and Description
NettyRpcClientConfigHelper()

Method Summary

Modifier and Type	Method and Description
static void	createEventLoopPerClient(org.apache.hadoop.conf.Configuration conf) The AsyncRpcClient will create its own NioEventLoopGroup.
static void	setEventLoopConfig(org.apache.hadoop.conf.Configuration conf, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup group, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass) Set the EventLoopGroup and channel class for AsyncRpcClient.

Methods inherited from class java.lang.Object

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

Field Detail

EVENT_LOOP_CONFIG

public static final String EVENT_LOOP_CONFIG

See Also:

Constant Field Values

Constructor Detail

NettyRpcClientConfigHelper

public NettyRpcClientConfigHelper()

Method Detail

setEventLoopConfig

public static void setEventLoopConfig(org.apache.hadoop.conf.Configuration conf,
                                      org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup group,
                                      Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)

Set the EventLoopGroup and channel class for AsyncRpcClient.

createEventLoopPerClient

public static void createEventLoopPerClient(org.apache.hadoop.conf.Configuration conf)

The AsyncRpcClient will create its own NioEventLoopGroup.