public interface Messenger<M>
Messengerserves as the routing system for messages between vertices. For distributed systems, the messenger can implement a "message passing" engine (distributed memory). For single machine systems, the messenger can implement a "state sharing" engine (shared memory). Each messenger is tied to the particular vertex distributing the message.
|Modifier and Type||Method and Description|
Receive all incoming messages to the currently executing vertex.
The currently executing vertex can send a message with provided
void sendMessage(MessageScope messageScope, M message)
messageScope- the message scope of the message being sent
message- the message to send
Copyright © 2013–2023 Apache Software Foundation. All rights reserved.