Re-exports§
pub use flarrow_layout;pub use flarrow_message;
Modules§
Structs§
- Dataflow
Layout - Represents a flattened dataflow layout
- Dataflow
Message - Dataflow message. Cheap to clone
- Header
- Header for a dataflow message
- Input
- Typed Input to receive data from the dataflow
- Input
Layout - Represents an input
- Inputs
- Inputs let you manage input connections during a node implementation
- NodeIO
Builder - This is the object passed to the user’s lambda function to build the node’s IO layout
- Node
Layout - Represents a node
- Output
- Typed Output to receive data from the dataflow
- Output
Layout - Represents an output
- Outputs
- Outputs let you manage output connections during a node implementation
- Queries
- Queries let you manage query connections during a node implementation
- Query
- Typed Query to query data from the dataflow
- Query
Layout - Represents a query
- Queryable
- Typed Queryable to queryable data to the dataflow
- Queryable
Layout - Represents a queryable
- Queryables
- Queryables let you manage queryable connections during a node implementation
- RawInput
- Not typed Input to receive data from the dataflow
- RawOutput
- Not typed Output to receive data from the dataflow
- RawQuery
- Not typed Query to receive data from the dataflow
- RawQueryable
- Not typed Queryable to receive data from the dataflow
Enums§
- IOLayout
- Represents a kind of IO (Input, Output, Query, Queryable)
Traits§
- Arrow
Message - Trait to represent a message that can be converted to and from an Arrow array.
- Node
Functions§
- extract_
union_ data - Helper function to extract data from a union array.
- get_
union_ fields - Helper function to get the union fields of a message.
- make_
union_ array - Helper function to create a union array.
- make_
union_ fields - Helper function to create a union field.
- unpack_
union - Helper function to unpack a union array.
Type Aliases§
- Dynamically
Linked Node Instance - Message
Receiver - MPSC Message receiver. Cannot be cloned
- Message
Sender - MPSC Message sender. Can be cloned, cheap to clone