Module timely::dataflow::operators::generic

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.
• FrontieredInputHandleCore
  Handle to an operator’s input stream and frontier.
• InputHandleCore
  Handle to an operator’s input stream.
• Notificator
  Tracks requests for notification and delivers available notifications.
• OperatorInfo
  Information about the operator being constructed
• OutputHandleCore
  Handle to an operator’s output stream.
• OutputWrapper
  An owned instance of an output buffer which ensures certain API use.

Type Aliases

• FrontieredInputHandle
  Handle to an operator’s input stream and frontier, specialized to vectors.
• InputHandle
  Handle to an operator’s input stream, specialized to vectors.
• OutputHandle
  Handle specialized to Vec-based container.