org.apache.spark.rpc

Interface IsolatedRpcEndpoint

All Superinterfaces:

RpcEndpoint

public interface IsolatedRpcEndpoint
extends RpcEndpoint

An endpoint that uses a dedicated thread pool for delivering messages.

Method Summary

Modifier and Type	Method and Description
int	threadCount() How many threads to use for delivering messages.

Methods inherited from interface org.apache.spark.rpc.RpcEndpoint

onConnected, onDisconnected, onError, onNetworkError, onStart, onStop, receive, receiveAndReply, rpcEnv, self, stop

Method Detail

threadCount

int threadCount()

How many threads to use for delivering messages. By default, use a single thread.

Note that requesting more than one thread means that the endpoint should be able to handle messages arriving from many threads at once, and all the things that entails (including messages being delivered to the endpoint out of order).

Returns:

(undocumented)