Package | Description |
---|---|
org.apache.hadoop.hdfs |
A distributed implementation of
FileSystem . |
org.apache.hadoop.hdfs.server.datanode | |
org.apache.hadoop.ipc |
Tools to help define network clients and servers.
|
Modifier and Type | Method and Description |
---|---|
static void |
DFSUtil.addPBProtocol(Configuration conf,
Class<?> protocol,
com.google.protobuf.BlockingService service,
RPC.Server server)
Add protobuf based protocol to the
RPC.Server |
Modifier and Type | Field and Description |
---|---|
RPC.Server |
DataNode.ipcServer |
Modifier and Type | Class and Description |
---|---|
static class |
ProtobufRpcEngine.Server |
static class |
WritableRpcEngine.Server
An RPC Server.
|
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.
|
RPC.Server |
RPC.Builder.build()
Build the RPC Server.
|
RPC.Server |
WritableRpcEngine.getServer(Class<?> protocolClass,
Object protocolImpl,
String bindAddress,
int port,
int numHandlers,
int numReaders,
int queueSizePerHandler,
boolean verbose,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig) |
RPC.Server |
ProtobufRpcEngine.getServer(Class<?> protocol,
Object protocolImpl,
String bindAddress,
int port,
int numHandlers,
int numReaders,
int queueSizePerHandler,
boolean verbose,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig) |
RPC.Server |
RpcEngine.getServer(Class<?> protocol,
Object instance,
String bindAddress,
int port,
int numHandlers,
int numReaders,
int queueSizePerHandler,
boolean verbose,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig)
Construct a server for a protocol implementation instance.
|
Constructor and Description |
---|
ProtocolMetaInfoServerSideTranslatorPB(RPC.Server server) |
Copyright © 2013 Apache Software Foundation. All rights reserved.