public class SharedMessageLoop extends MessageLoop
Constructor and Description |
---|
SharedMessageLoop(SparkConf conf,
org.apache.spark.rpc.netty.Dispatcher dispatcher,
int numUsableCores) |
Modifier and Type | Method and Description |
---|---|
void |
post(String endpointName,
InboxMessage message) |
void |
register(String name,
RpcEndpoint endpoint) |
void |
unregister(String name) |
PoisonPill, stop
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeLogging, initializeLogIfNecessary, initializeLogIfNecessary, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public SharedMessageLoop(SparkConf conf, org.apache.spark.rpc.netty.Dispatcher dispatcher, int numUsableCores)
public void post(String endpointName, InboxMessage message)
post
in class MessageLoop
public void register(String name, RpcEndpoint endpoint)
public void unregister(String name)
unregister
in class MessageLoop