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
private static String	CONFIG_NAME
static String	EVENT_LOOP_CONFIG
private static Map<String,Pair<org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup,Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>>>	EVENT_LOOP_CONFIG_MAP

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.
(package private) static Pair<org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup,Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>>	getEventLoopConfig(org.apache.hadoop.conf.Configuration conf)
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

CONFIG_NAME

private static final String CONFIG_NAME

See Also:

Constant Field Values

EVENT_LOOP_CONFIG_MAP

private static final Map<String,Pair<org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup,Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>>> EVENT_LOOP_CONFIG_MAP

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.

getEventLoopConfig

static Pair<org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup,Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>> getEventLoopConfig(org.apache.hadoop.conf.Configuration conf)