org.apache.spark.internal.plugin

Class PluginEndpoint

Object

org.apache.spark.internal.plugin.PluginEndpoint

All Implemented Interfaces:

Logging, IsolatedRpcEndpoint, RpcEndpoint

public class PluginEndpoint
extends Object
implements IsolatedRpcEndpoint, Logging

Constructor Summary

Constructors

Constructor and Description
PluginEndpoint(scala.collection.immutable.Map<String,DriverPlugin> plugins, org.apache.spark.rpc.RpcEnv rpcEnv)

Method Summary

Modifier and Type	Method and Description
scala.PartialFunction<Object,scala.runtime.BoxedUnit>	receive() Process messages from RpcEndpointRef.send or RpcCallContext.reply.
scala.PartialFunction<Object,scala.runtime.BoxedUnit>	receiveAndReply(RpcCallContext context) Process messages from RpcEndpointRef.ask.
org.apache.spark.rpc.RpcEnv	rpcEnv() The RpcEnv that this RpcEndpoint is registered to.

Methods inherited from class Object

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

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

threadCount

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

onConnected, onDisconnected, onError, onNetworkError, onStart, onStop, self, stop

Methods inherited from interface org.apache.spark.internal.Logging

initializeForcefully, initializeLogging, initializeLogIfNecessary, initializeLogIfNecessary, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

PluginEndpoint

public PluginEndpoint(scala.collection.immutable.Map<String,DriverPlugin> plugins,
                      org.apache.spark.rpc.RpcEnv rpcEnv)

Method Detail

receive

public scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive()

Description copied from interface: RpcEndpoint

Process messages from RpcEndpointRef.send or RpcCallContext.reply. If receiving a unmatched message, SparkException will be thrown and sent to onError.

Specified by:

receive in interface RpcEndpoint

Returns:

(undocumented)

receiveAndReply

public scala.PartialFunction<Object,scala.runtime.BoxedUnit> receiveAndReply(RpcCallContext context)

Description copied from interface: RpcEndpoint

Process messages from RpcEndpointRef.ask. If receiving a unmatched message, SparkException will be thrown and sent to onError.

Specified by:

receiveAndReply in interface RpcEndpoint

Parameters:

context - (undocumented)

Returns:

(undocumented)

rpcEnv

public org.apache.spark.rpc.RpcEnv rpcEnv()

Description copied from interface: RpcEndpoint

The RpcEnv that this RpcEndpoint is registered to.

Specified by:

rpcEnv in interface RpcEndpoint

Returns:

(undocumented)