Package | Description |
---|---|
org.apache.hadoop.ipc |
Tools to help define network clients and servers.
|
org.apache.hadoop.util |
Common utilities.
|
Modifier and Type | Method and Description |
---|---|
static RPC.RpcKind |
RPC.RpcKind.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static RPC.RpcKind[] |
RPC.RpcKind.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
RPC.Server |
RPC.Server.addProtocol(RPC.RpcKind rpcKind,
Class<?> protocolClass,
Object protocolImpl)
Add a protocol to the existing server.
|
abstract Writable |
Server.call(RPC.RpcKind rpcKind,
String protocol,
Writable param,
long receiveTime)
Called for each call.
|
Writable |
RPC.Server.call(RPC.RpcKind rpcKind,
String protocol,
Writable rpcRequest,
long receiveTime) |
Writable |
Client.call(RPC.RpcKind rpcKind,
Writable rpcRequest,
Client.ConnectionId remoteId)
Make a call, passing
rpcRequest , to the IPC server defined by
remoteId , returning the rpc respond. |
Writable |
Client.call(RPC.RpcKind rpcKind,
Writable rpcRequest,
Client.ConnectionId remoteId,
int serviceClass)
Make a call, passing
rpcRequest , to the IPC server defined by
remoteId , returning the rpc respond. |
Writable |
Client.call(RPC.RpcKind rpcKind,
Writable param,
InetSocketAddress address)
Deprecated.
Use
Client.call(RPC.RpcKind, Writable,
ConnectionId) instead |
Writable |
Client.call(RPC.RpcKind rpcKind,
Writable param,
InetSocketAddress addr,
Class<?> protocol,
UserGroupInformation ticket,
int rpcTimeout)
Deprecated.
Use
Client.call(RPC.RpcKind, Writable,
ConnectionId) instead |
Writable |
Client.call(RPC.RpcKind rpcKind,
Writable param,
InetSocketAddress addr,
Class<?> protocol,
UserGroupInformation ticket,
int rpcTimeout,
Configuration conf)
Make a call, passing
param , to the IPC server running at
address which is servicing the protocol protocol,
with the ticket credentials, rpcTimeout as
timeout and conf as conf for this connection, returning the
value. |
Writable |
Client.call(RPC.RpcKind rpcKind,
Writable param,
InetSocketAddress addr,
UserGroupInformation ticket)
Deprecated.
Use
Client.call(RPC.RpcKind, Writable,
ConnectionId) instead |
static org.apache.hadoop.ipc.RPC.RpcInvoker |
Server.getRpcInvoker(RPC.RpcKind rpcKind) |
static boolean |
RpcClientUtil.isMethodSupported(Object rpcProxy,
Class<?> protocol,
RPC.RpcKind rpcKind,
long version,
String methodName)
Returns whether the given method is supported or not.
|
static void |
Server.registerProtocolEngine(RPC.RpcKind rpcKind,
Class<? extends Writable> rpcRequestWrapperClass,
org.apache.hadoop.ipc.RPC.RpcInvoker rpcInvoker)
Register a RPC kind and the class to deserialize the rpc request.
|
Constructor and Description |
---|
Server.Call(int id,
int retryCount,
Writable param,
Server.Connection connection,
RPC.RpcKind kind,
byte[] clientId) |
Modifier and Type | Method and Description |
---|---|
static RPC.RpcKind |
ProtoUtil.convert(RpcHeaderProtos.RpcKindProto kind) |
Modifier and Type | Method and Description |
---|---|
static RpcHeaderProtos.RpcRequestHeaderProto |
ProtoUtil.makeRpcRequestHeader(RPC.RpcKind rpcKind,
RpcHeaderProtos.RpcRequestHeaderProto.OperationProto operation,
int callId,
int retryCount,
byte[] uuid) |
Copyright © 2013 Apache Software Foundation. All rights reserved.