Package org.apache.flink.runtime.rpc

Interface FencedRpcGateway<F extends Serializable>

Type Parameters:

F - type of the fencing token

All Superinterfaces:

RpcGateway

All Known Subinterfaces:

DispatcherGateway, JobMasterGateway, ResourceManagerGateway

All Known Implementing Classes:

ActiveResourceManager, Dispatcher, FencedPekkoInvocationHandler, JobMaster, MiniDispatcher, ResourceManager, StandaloneDispatcher, StandaloneResourceManager

public interface FencedRpcGateway<F extends Serializable>
extends RpcGateway

Fenced RpcGateway. This gateway allows to have access to the associated fencing token.

Method Summary

Modifier and Type	Method	Description
F	getFencingToken()	Get the current fencing token.

Methods inherited from interface org.apache.flink.runtime.rpc.RpcGateway

getAddress, getHostname

Method Detail

getFencingToken

F getFencingToken()

Get the current fencing token.

Returns:

current fencing token