public class CheckpointCoordinatorDeActivator extends FlinkUntypedActor
LOG
Constructor and Description |
---|
CheckpointCoordinatorDeActivator(CheckpointCoordinator coordinator,
UUID leaderSessionID) |
Modifier and Type | Method and Description |
---|---|
UUID |
getLeaderSessionID()
Returns the current leader session ID associcated with this actor.
|
void |
handleMessage(Object message)
This method contains the actor logic which defines how to react to incoming messages.
|
decorateMessage, onReceive
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled
public CheckpointCoordinatorDeActivator(CheckpointCoordinator coordinator, UUID leaderSessionID)
public void handleMessage(Object message)
FlinkUntypedActor
handleMessage
in class FlinkUntypedActor
message
- Incoming messagepublic UUID getLeaderSessionID()
FlinkUntypedActor
getLeaderSessionID
in class FlinkUntypedActor
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.