org.apache.flink.runtime.rpc.akka

Class AkkaRpcSystemLoader

java.lang.Object

org.apache.flink.runtime.rpc.akka.AkkaRpcSystemLoader

All Implemented Interfaces:

RpcSystemLoader

public class AkkaRpcSystemLoader
extends Object
implements RpcSystemLoader

Loader for the AkkaRpcSystemLoader.

This loader expects the flink-rpc-akka jar to be accessible via ClassLoader.getResource(String). It will extract the jar into a temporary directory and create a new SubmoduleClassLoader to load the rpc system from that jar.

Constructor Summary

Constructors

Constructor and Description
AkkaRpcSystemLoader()

Method Summary

Modifier and Type	Method and Description
RpcSystem	loadRpcSystem(Configuration config)

Methods inherited from class java.lang.Object

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

Constructor Detail

AkkaRpcSystemLoader

public AkkaRpcSystemLoader()

Method Detail

loadRpcSystem

public RpcSystem loadRpcSystem(Configuration config)

Specified by:

loadRpcSystem in interface RpcSystemLoader