org.apache.hadoop.hbase.client

Class ServerConnectionUtils

java.lang.Object

org.apache.hadoop.hbase.client.ServerConnectionUtils

@InterfaceAudience.Private
public final class ServerConnectionUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ServerConnectionUtils.ShortCircuitingClusterConnection A ClusterConnection that will short-circuit RPC making direct invocations against the localhost if the invocation target is 'this' server; save on network and protobuf invocations.

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ServerConnectionUtils()

Method Summary

Modifier and Type

Method and Description

static ClusterConnection

createShortCircuitConnection(org.apache.hadoop.conf.Configuration conf, User user, ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface admin, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface client, ConnectionRegistry registry) Creates a short-circuit connection that can bypass the RPC layer (serialization, deserialization, networking, etc..) when talking to a local server.

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerConnectionUtils

private ServerConnectionUtils()

Method Detail

createShortCircuitConnection

public static ClusterConnection createShortCircuitConnection(org.apache.hadoop.conf.Configuration conf,
                                                             User user,
                                                             ServerName serverName,
                                                             org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface admin,
                                                             org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface client,
                                                             ConnectionRegistry registry)
                                                      throws IOException

Creates a short-circuit connection that can bypass the RPC layer (serialization, deserialization, networking, etc..) when talking to a local server.

Parameters:

conf - the current configuration

user - the user the connection is for

serverName - the local server name

admin - the admin interface of the local server

client - the client interface of the local server

registry - the connection registry to be used, can be null

Returns:

an short-circuit connection.

Throws:

IOException - if IO failure occurred