org.apache.spark.util
Class RpcUtils

Object
  org.apache.spark.util.RpcUtils

public class RpcUtils
extends Object

Constructor Summary

RpcUtils()

Method Summary

static scala.concurrent.duration.FiniteDuration	askTimeout(SparkConf conf) Returns the default Spark timeout to use for RPC ask operations.
static scala.concurrent.duration.FiniteDuration	lookupTimeout(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	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

askTimeout

public static scala.concurrent.duration.FiniteDuration askTimeout(SparkConf conf)

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

lookupTimeout

public static scala.concurrent.duration.FiniteDuration lookupTimeout(SparkConf conf)

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