org.apache.spark.util

Class RpcUtils

Object

org.apache.spark.util.RpcUtils

public class RpcUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
RpcUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.spark.rpc.RpcTimeout	askRpcTimeout(SparkConf conf) Returns the default Spark timeout to use for RPC ask operations.
static org.apache.spark.rpc.RpcTimeout	INFINITE_TIMEOUT() Infinite timeout is used internally, so there's no timeout configuration property that controls it.
static org.apache.spark.rpc.RpcTimeout	lookupRpcTimeout(SparkConf conf) Returns the default Spark timeout to use for RPC remote endpoint lookup.
static org.apache.spark.rpc.RpcEndpointRef	makeDriverRef(String name, SparkConf conf, org.apache.spark.rpc.RpcEnv rpcEnv) Retrieve a RpcEndpointRef which is located in the driver via its name.
static int	maxMessageSizeBytes(SparkConf conf) Returns the configured max message size for messages in bytes.
static int	numRetries(SparkConf conf) Returns the configured number of times to retry connecting
static long	retryWaitMs(SparkConf conf) Returns the configured number of milliseconds to wait on each retry

Methods inherited from class Object

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

Constructor Detail

RpcUtils

public RpcUtils()

Method Detail

makeDriverRef

public static org.apache.spark.rpc.RpcEndpointRef makeDriverRef(String name,
                                                                SparkConf conf,
                                                                org.apache.spark.rpc.RpcEnv rpcEnv)

Retrieve a RpcEndpointRef which is located in the driver via its name.

Parameters:

name - (undocumented)

conf - (undocumented)

rpcEnv - (undocumented)

Returns:

(undocumented)

numRetries

public static int numRetries(SparkConf conf)

Returns the configured number of times to retry connecting

retryWaitMs

public static long retryWaitMs(SparkConf conf)

Returns the configured number of milliseconds to wait on each retry

askRpcTimeout

public static org.apache.spark.rpc.RpcTimeout askRpcTimeout(SparkConf conf)

Returns the default Spark timeout to use for RPC ask operations.

lookupRpcTimeout

public static org.apache.spark.rpc.RpcTimeout lookupRpcTimeout(SparkConf conf)

Returns the default Spark timeout to use for RPC remote endpoint lookup.

INFINITE_TIMEOUT

public static org.apache.spark.rpc.RpcTimeout INFINITE_TIMEOUT()

Infinite timeout is used internally, so there's no timeout configuration property that controls it. Therefore, we use "infinite" without any specific reason as its timeout configuration property. And its timeout property should never be accessed since infinite means we never timeout.

Returns:

(undocumented)

maxMessageSizeBytes

public static int maxMessageSizeBytes(SparkConf conf)

Returns the configured max message size for messages in bytes.