Class MiniCluster.DedicatedRpcServiceFactory
- java.lang.Object
-
- org.apache.flink.runtime.minicluster.MiniCluster.DedicatedRpcServiceFactory
-
- All Implemented Interfaces:
MiniCluster.RpcServiceFactory
- Enclosing class:
- MiniCluster
protected class MiniCluster.DedicatedRpcServiceFactory extends Object implements MiniCluster.RpcServiceFactory
Factory which creates and registers newRpcService
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RpcService
createRpcService()
-
-
-
Method Detail
-
createRpcService
public RpcService createRpcService() throws Exception
- Specified by:
createRpcService
in interfaceMiniCluster.RpcServiceFactory
- Throws:
Exception
-
-