org.apache.flink.runtime.rpc

Class PermanentlyFencedRpcEndpoint<F extends Serializable>

java.lang.Object

org.apache.flink.runtime.rpc.RpcEndpoint

org.apache.flink.runtime.rpc.FencedRpcEndpoint<F>

org.apache.flink.runtime.rpc.PermanentlyFencedRpcEndpoint<F>

Type Parameters:

F - type of the fencing token.

All Implemented Interfaces:

AutoCloseable, RpcGateway, AutoCloseableAsync

Direct Known Subclasses:

Dispatcher

public class PermanentlyFencedRpcEndpoint<F extends Serializable>
extends FencedRpcEndpoint<F>

FencedRpcEndpoint which is fenced with a fencing token which is bound to the lifetime of the rpc endpoint.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.runtime.rpc.RpcEndpoint

RpcEndpoint.MainThreadExecutor

Field Summary

Fields inherited from class org.apache.flink.runtime.rpc.RpcEndpoint

log, rpcServer

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PermanentlyFencedRpcEndpoint(RpcService rpcService, F fencingToken)
protected	PermanentlyFencedRpcEndpoint(RpcService rpcService, String endpointId, F fencingToken)

Method Summary

Modifier and Type	Method and Description
protected void	setFencingToken(F newFencingToken)

Methods inherited from class org.apache.flink.runtime.rpc.FencedRpcEndpoint

callAsyncWithoutFencing, getFencingToken, getMainThreadExecutor, getUnfencedMainThreadExecutor, runAsyncWithoutFencing

Methods inherited from class org.apache.flink.runtime.rpc.RpcEndpoint

callAsync, closeAsync, getAddress, getEndpointId, getHostname, getRpcService, getSelfGateway, getTerminationFuture, internalCallOnStart, internalCallOnStop, isRunning, onStart, onStop, runAsync, scheduleRunAsync, scheduleRunAsync, start, stop, validateRunsInMainThread

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close

Constructor Detail

PermanentlyFencedRpcEndpoint

protected PermanentlyFencedRpcEndpoint(RpcService rpcService,
                                       String endpointId,
                                       F fencingToken)

PermanentlyFencedRpcEndpoint

protected PermanentlyFencedRpcEndpoint(RpcService rpcService,
                                       F fencingToken)

Method Detail

setFencingToken

protected void setFencingToken(@Nullable
                               F newFencingToken)

Overrides:

setFencingToken in class FencedRpcEndpoint<F extends Serializable>