org.apache.flink.runtime.rpc.pekko

Class PekkoRpcSystemLoader

java.lang.Object

org.apache.flink.runtime.rpc.pekko.PekkoRpcSystemLoader

All Implemented Interfaces:

RpcSystemLoader

public class PekkoRpcSystemLoader
extends Object
implements RpcSystemLoader

Loader for the PekkoRpcSystemLoader.

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
PekkoRpcSystemLoader()

Method Summary

Modifier and Type	Method and Description
int	getLoadPriority() Returns the loading priority for this loader, for a deterministic loading order if multiple rpc system loaders are present on the classpath.
RpcSystem	loadRpcSystem(Configuration config)

Methods inherited from class java.lang.Object

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

Constructor Detail

PekkoRpcSystemLoader

public PekkoRpcSystemLoader()

Method Detail

getLoadPriority

public int getLoadPriority()

Description copied from interface: RpcSystemLoader

Returns the loading priority for this loader, for a deterministic loading order if multiple rpc system loaders are present on the classpath. 0 designates the highest priority.

Specified by:

getLoadPriority in interface RpcSystemLoader

loadRpcSystem

public RpcSystem loadRpcSystem(Configuration config)

Specified by:

loadRpcSystem in interface RpcSystemLoader