Ask a question to get started
Enter to send•Shift+Enter new line
Stores the result of applying a binary operator to the current value and each new value.
import operator total = Channels.BinaryOperatorAggregate(int, operator.add)
BinaryOperatorAggregate( self, typ: type[Value], operator: Callable[[Value, Value], Value] )
Generic[Value]
BaseChannel[Value, Value, Value]
The type of the value stored in the channel.
The type of the update received by the channel.
Return a copy of the channel.
Notify the channel that a subscribed task ran.
Notify the channel that the Pregel run is finishing.
