Package org.apache.flink.runtime.rpc.pekko

Class FencedPekkoRpcActor<F extends Serializable,T extends org.apache.flink.runtime.rpc.FencedRpcEndpoint<F> & org.apache.flink.runtime.rpc.RpcGateway>

java.lang.Object

org.apache.pekko.actor.AbstractActor

org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor<F,T>

Type Parameters:

F - type of the fencing token

T - type of the RpcEndpoint

All Implemented Interfaces:

org.apache.pekko.actor.Actor

public class FencedPekkoRpcActor<F extends Serializable,T extends org.apache.flink.runtime.rpc.FencedRpcEndpoint<F> & org.apache.flink.runtime.rpc.RpcGateway>
extends org.apache.pekko.actor.AbstractActor

Fenced extension of the PekkoRpcActor. This actor will be started for FencedRpcEndpoint and is responsible for filtering out invalid messages with respect to the current fencing token.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.actor.AbstractActor

org.apache.pekko.actor.AbstractActor.ActorContext, org.apache.pekko.actor.AbstractActor.Receive

Nested classes/interfaces inherited from interface org.apache.pekko.actor.Actor

org.apache.pekko.actor.Actor.emptyBehavior$, org.apache.pekko.actor.Actor.ignoringBehavior$

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	log
protected T	rpcEndpoint	the endpoint to invoke the methods on.

Constructor Summary

Constructors

Constructor	Description
FencedPekkoRpcActor(T rpcEndpoint, CompletableFuture<Boolean> terminationFuture, int version, long maximumFramesize, boolean forceSerialization, ClassLoader flinkClassLoader, Map<String,String> loggingContext)

Method Summary

Modifier and Type	Method	Description
org.apache.pekko.actor.AbstractActor.Receive	createReceive()
protected Object	envelopeSelfMessage(Object message)	Hook to envelope self messages.
protected void	handleRpcMessage(Object message)
void	postStop()
protected void	sendErrorIfSender(Throwable throwable)	Send throwable to sender if the sender is specified.

Methods inherited from class org.apache.pekko.actor.AbstractActor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, emptyBehavior, getContext, getSelf, getSender, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, postRestart, preRestart, preRestart, preStart, receive, receiveBuilder, self, sender, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.slf4j.Logger log

rpcEndpoint

protected final T extends org.apache.flink.runtime.rpc.RpcEndpoint & org.apache.flink.runtime.rpc.RpcGateway rpcEndpoint

the endpoint to invoke the methods on.

Constructor Detail

FencedPekkoRpcActor

public FencedPekkoRpcActor(T rpcEndpoint,
                           CompletableFuture<Boolean> terminationFuture,
                           int version,
                           long maximumFramesize,
                           boolean forceSerialization,
                           ClassLoader flinkClassLoader,
                           Map<String,String> loggingContext)

Method Detail

handleRpcMessage

protected void handleRpcMessage(Object message)

envelopeSelfMessage

protected Object envelopeSelfMessage(Object message)

Hook to envelope self messages.

Parameters:

message - to envelope

Returns:

enveloped message

postStop

public void postStop()
              throws Exception

Specified by:

postStop in interface org.apache.pekko.actor.Actor

Overrides:

postStop in class org.apache.pekko.actor.AbstractActor

Throws:

Exception

createReceive

public org.apache.pekko.actor.AbstractActor.Receive createReceive()

Specified by:

createReceive in class org.apache.pekko.actor.AbstractActor

sendErrorIfSender

protected void sendErrorIfSender(Throwable throwable)

Send throwable to sender if the sender is specified.

Parameters:

throwable - to send to the sender