Module timely::dataflow::operators::generic [−][src]
Generic operators defined by user-provided closures.
Re-exports
pub use self::operator::Operator; |
pub use self::operator::source; |
Modules
builder_raw | Types to build operators with general shapes. |
builder_rc | Types to build operators with general shapes. |
operator | Methods to construct generic streaming and blocking unary operators. |
Structs
FrontierNotificator | Tracks requests for notification and delivers available notifications. |
FrontieredInputHandle | Handle to an operator’s input stream and frontier. |
InputHandle | Handle to an operator’s input stream. |
Notificator | Tracks requests for notification and delivers available notifications. |
OperatorInfo | Information about the operator being constructed |
OutputHandle | Handle to an operator’s output stream. |
OutputWrapper | An owned instance of an output buffer which ensures certain API use. |