Struct pregel_rs::pregel::SendMessage
source · pub struct SendMessage<'a> {
pub message_direction: Expr,
pub send_message: Box<dyn FnMut() -> Expr + 'a>,
}
Expand description
This defines a struct SendMessage
in Rust. It has two properties:
message_direction
and send_message
. The message_direction
property
is the identifier for the direction of the message. The send_message
property is the function that determines which messages to send from a
vertex to its neighbors.
Fields§
§message_direction: Expr
message_direction
is the identifier for the direction of the message.
send_message: Box<dyn FnMut() -> Expr + 'a>
send_message
is the function that determines which messages to send from a
vertex to its neighbors.
Implementations§
source§impl<'a> SendMessage<'a>
impl<'a> SendMessage<'a>
sourcepub fn new(
message_direction: MessageReceiver,
send_message: Box<dyn FnMut() -> Expr + '_>
) -> SendMessage<'_>
pub fn new( message_direction: MessageReceiver, send_message: Box<dyn FnMut() -> Expr + '_> ) -> SendMessage<'_>
The function creates a new instance of the SendMessage
struct with the
specified message direction and send message expression.
Arguments:
message_direction
: An enum that specifies whether the message should be sent to the source vertex or the destination vertex of an edge.send_message
:send_message
is an expression that represents the message that will be sent from a vertex to its neighbors during the Pregel computation. It can be any valid Rust expression that evaluates to a DataFrame.
Returns:
A new instance of the SendMessage
struct.
Auto Trait Implementations§
impl<'a> !RefUnwindSafe for SendMessage<'a>
impl<'a> !Send for SendMessage<'a>
impl<'a> !Sync for SendMessage<'a>
impl<'a> Unpin for SendMessage<'a>
impl<'a> !UnwindSafe for SendMessage<'a>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more