org.apache.hadoop.hbase.ipc

Class NettyRpcClientConfigHelper

java.lang.Object

org.apache.hadoop.hbase.ipc.NettyRpcClientConfigHelper

@InterfaceAudience.Public
public final 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
private static Pair<org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup,Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>>	DEFAULT_EVENT_LOOP
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
static String	HBASE_NETTY_EVENTLOOP_RPCCLIENT_THREADCOUNT_KEY Name of property to change netty rpc client eventloop thread count.

Constructor Summary

Constructors

Modifier	Constructor and Description
private	NettyRpcClientConfigHelper() Shutdown constructor.

Method Summary

Modifier and Type	Method and Description
static void	createEventLoopPerClient(org.apache.hadoop.conf.Configuration conf) The NettyRpcClient will create its own NioEventLoopGroup.
private static Pair<org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup,Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>>	getDefaultEventLoopConfig(org.apache.hadoop.conf.Configuration conf)
(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

HBASE_NETTY_EVENTLOOP_RPCCLIENT_THREADCOUNT_KEY

public static final String HBASE_NETTY_EVENTLOOP_RPCCLIENT_THREADCOUNT_KEY

Name of property to change netty rpc client eventloop thread count. Default is 0. Tests may set this down from unlimited.

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

DEFAULT_EVENT_LOOP

private static volatile Pair<org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup,Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>> DEFAULT_EVENT_LOOP

Constructor Detail

NettyRpcClientConfigHelper

private NettyRpcClientConfigHelper()

Shutdown constructor.

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 NettyRpcClient will create its own NioEventLoopGroup.

getDefaultEventLoopConfig

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

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)