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>

  • 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.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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

    • 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)

    • 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