org.apache.hadoop.ipc

Class RPC.Builder

java.lang.Object

org.apache.hadoop.ipc.RPC.Builder

Enclosing class:

RPC

public static class RPC.Builder
extends Object

Class to construct instances of RPC server with specific options.

Constructor Summary

Constructors

Constructor and Description
RPC.Builder(Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
RPC.Server	build() Build the RPC Server.
RPC.Builder	setBindAddress(String bindAddress) Default: 0.0.0.0
RPC.Builder	setInstance(Object instance) Mandatory field
RPC.Builder	setNumHandlers(int numHandlers) Default: 1
RPC.Builder	setnumReaders(int numReaders) Default: -1
RPC.Builder	setPort(int port) Default: 0
RPC.Builder	setPortRangeConfig(String portRangeConfig) Default: null
RPC.Builder	setProtocol(Class<?> protocol) Mandatory field
RPC.Builder	setQueueSizePerHandler(int queueSizePerHandler) Default: -1
RPC.Builder	setSecretManager(SecretManager<? extends TokenIdentifier> secretManager) Default: null
RPC.Builder	setVerbose(boolean verbose) Default: false

Methods inherited from class java.lang.Object

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

Constructor Detail

RPC.Builder

public RPC.Builder(Configuration conf)

Method Detail

setProtocol

public RPC.Builder setProtocol(Class<?> protocol)

Mandatory field

setInstance

public RPC.Builder setInstance(Object instance)

Mandatory field

setBindAddress

public RPC.Builder setBindAddress(String bindAddress)

Default: 0.0.0.0

setPort

public RPC.Builder setPort(int port)

Default: 0

setNumHandlers

public RPC.Builder setNumHandlers(int numHandlers)

Default: 1

setnumReaders

public RPC.Builder setnumReaders(int numReaders)

Default: -1

setQueueSizePerHandler

public RPC.Builder setQueueSizePerHandler(int queueSizePerHandler)

Default: -1

setVerbose

public RPC.Builder setVerbose(boolean verbose)

Default: false

setSecretManager

public RPC.Builder setSecretManager(SecretManager<? extends TokenIdentifier> secretManager)

Default: null

setPortRangeConfig

public RPC.Builder setPortRangeConfig(String portRangeConfig)

Default: null

build

public RPC.Server build()
                 throws IOException,
                        HadoopIllegalArgumentException

Build the RPC Server.

Throws:

IOException - on error

HadoopIllegalArgumentException - when mandatory fields are not set