Struct hydroflow_plus::builder::compiled::CompiledFlow
source · pub struct CompiledFlow<'a, ID> { /* private fields */ }Implementations§
source§impl<ID> CompiledFlow<'_, ID>
impl<ID> CompiledFlow<'_, ID>
source§impl<'a> CompiledFlow<'a, usize>
impl<'a> CompiledFlow<'a, usize>
pub fn with_dynamic_id(
+CompiledFlow in hydroflow_plus::builder::compiled - Rust Struct hydroflow_plus::builder::compiled::CompiledFlow
source · pub struct CompiledFlow<'a, ID> { /* private fields */ }
Implementations§
source§impl<ID> CompiledFlow<'_, ID>
sourcepub fn hydroflow_ir(&self) -> &BTreeMap<usize, HydroflowGraph>
sourcepub fn take_ir(self) -> BTreeMap<usize, HydroflowGraph>
source§impl<'a> CompiledFlow<'a, usize>
sourcepub fn with_dynamic_id(
self,
id: impl QuotedWithContext<'a, usize, ()>,
) -> CompiledFlowWithId<'a>
Trait Implementations§
source§impl<'a, Ctx> FreeVariableWithContext<Ctx> for CompiledFlow<'a, ()>
source§impl<'a, Ctx> QuotedWithContext<'a, Hydroflow<'a>, Ctx> for CompiledFlow<'a, ()>
source§fn splice_untyped_ctx(self, ctx: &Ctx) -> Exprwhere
diff --git a/doc/hydroflow_plus/deploy/in_memory_graph/struct.MultiNode.html b/doc/hydroflow_plus/deploy/in_memory_graph/struct.MultiNode.html
index 26584118f5b9..6b0e486ebfa8 100644
--- a/doc/hydroflow_plus/deploy/in_memory_graph/struct.MultiNode.html
+++ b/doc/hydroflow_plus/deploy/in_memory_graph/struct.MultiNode.html
@@ -2,7 +2,7 @@
&self,
_env: &mut Self::InstantiateEnv,
_meta: &mut Self::Meta,
- _graph: HydroflowGraph,
+ _graph: HydroflowGraph,
_extra_stmts: Vec<Stmt>,
)
Auto Trait Implementations§
§impl Freeze for MultiNode
§impl RefUnwindSafe for MultiNode
§impl Send for MultiNode
§impl Sync for MultiNode
§impl Unpin for MultiNode
§impl UnwindSafe for MultiNode
Blanket Implementations§
source§impl<T> Borrow<T> for Twhere
diff --git a/doc/hydroflow_plus/deploy/in_memory_graph/struct.SingleNode.html b/doc/hydroflow_plus/deploy/in_memory_graph/struct.SingleNode.html
index 32a0b5a0f716..466af81c388f 100644
--- a/doc/hydroflow_plus/deploy/in_memory_graph/struct.SingleNode.html
+++ b/doc/hydroflow_plus/deploy/in_memory_graph/struct.SingleNode.html
@@ -2,7 +2,7 @@
&self,
_env: &mut Self::InstantiateEnv,
_meta: &mut Self::Meta,
- _graph: HydroflowGraph,
+ _graph: HydroflowGraph,
_extra_stmts: Vec<Stmt>,
)
Auto Trait Implementations§
§impl Freeze for SingleNode
§impl RefUnwindSafe for SingleNode
§impl Send for SingleNode
§impl Sync for SingleNode
§impl Unpin for SingleNode
§impl UnwindSafe for SingleNode
Blanket Implementations§
source§impl<T> Borrow<T> for Twhere
diff --git a/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeCluster.html b/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeCluster.html
index 08e204ad51c2..d902bb327662 100644
--- a/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeCluster.html
+++ b/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeCluster.html
@@ -2,7 +2,7 @@
&self,
_env: &mut Self::InstantiateEnv,
_meta: &mut Self::Meta,
- _graph: HydroflowGraph,
+ _graph: HydroflowGraph,
_extra_stmts: Vec<Stmt>,
)
Auto Trait Implementations§
§impl Freeze for DeployRuntimeCluster
§impl !RefUnwindSafe for DeployRuntimeCluster
§impl !Send for DeployRuntimeCluster
§impl !Sync for DeployRuntimeCluster
§impl Unpin for DeployRuntimeCluster
§impl !UnwindSafe for DeployRuntimeCluster
Blanket Implementations§
source§impl<T> Borrow<T> for Twhere
diff --git a/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeNode.html b/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeNode.html
index 0db9cb236779..a99bd2986d76 100644
--- a/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeNode.html
+++ b/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeNode.html
@@ -2,7 +2,7 @@
&self,
_env: &mut Self::InstantiateEnv,
_meta: &mut Self::Meta,
- _graph: HydroflowGraph,
+ _graph: HydroflowGraph,
_extra_stmts: Vec<Stmt>,
)
source§impl<'a> RegisterPort<'a, DeployRuntime> for DeployRuntimeNode
source§fn register(&self, _key: usize, _port: <DeployRuntime as Deploy<'_>>::Port)
source§fn raw_port(
&self,
diff --git a/doc/hydroflow_plus/deploy/trait.Node.html b/doc/hydroflow_plus/deploy/trait.Node.html
index 1443f5c5da02..6a0c02090a41 100644
--- a/doc/hydroflow_plus/deploy/trait.Node.html
+++ b/doc/hydroflow_plus/deploy/trait.Node.html
@@ -10,13 +10,13 @@
&self,
env: &mut Self::InstantiateEnv,
meta: &mut Self::Meta,
- graph: HydroflowGraph,
+ graph: HydroflowGraph,
extra_stmts: Vec<Stmt>,
);
}Required Associated Types§
Required Methods§
sourcefn next_port(&self) -> Self::Port
sourcefn update_meta(&mut self, meta: &Self::Meta)
sourcefn instantiate(
&self,
env: &mut Self::InstantiateEnv,
meta: &mut Self::Meta,
- graph: HydroflowGraph,
+ graph: HydroflowGraph,
extra_stmts: Vec<Stmt>,
)
Implementors§
\ No newline at end of file
diff --git a/doc/hydroflow_plus/ir/enum.HfPlusLeaf.html b/doc/hydroflow_plus/ir/enum.HfPlusLeaf.html
index 87792ebabd43..3a8f4455754c 100644
--- a/doc/hydroflow_plus/ir/enum.HfPlusLeaf.html
+++ b/doc/hydroflow_plus/ir/enum.HfPlusLeaf.html
@@ -28,7 +28,7 @@
seen_tees: &mut SeenTees,
) -> HfPlusLeafsourcepub fn emit(
&self,
- graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>,
+ graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>,
built_tees: &mut HashMap<*const RefCell<HfPlusNode>, (Ident, usize)>,
next_stmt_id: &mut usize,
)
Trait Implementations§
Auto Trait Implementations§
§impl Freeze for HfPlusLeaf
§impl !RefUnwindSafe for HfPlusLeaf
§impl !Send for HfPlusLeaf
§impl !Sync for HfPlusLeaf
§impl Unpin for HfPlusLeaf
§impl !UnwindSafe for HfPlusLeaf
Blanket Implementations§
source§impl<T> Any for Twhere
diff --git a/doc/hydroflow_plus/ir/enum.HfPlusNode.html b/doc/hydroflow_plus/ir/enum.HfPlusNode.html
index 78e5a2a0fcb0..cc37075ae514 100644
--- a/doc/hydroflow_plus/ir/enum.HfPlusNode.html
+++ b/doc/hydroflow_plus/ir/enum.HfPlusNode.html
@@ -70,14 +70,14 @@
from_key: Option<usize>,
to_location: LocationId,
to_key: Option<usize>,
- serialize_pipeline: Option<Pipeline>,
+ serialize_pipeline: Option<Pipeline>,
instantiate_fn: DebugInstantiate,
- deserialize_pipeline: Option<Pipeline>,
+ deserialize_pipeline: Option<Pipeline>,
input: Box<HfPlusNode>,
},
}Expand description
An intermediate node in a Hydroflow+ graph, which consumes data
from upstream nodes and emits data to downstream nodes.
-Variants§
§Placeholder
§Source
§CycleSource
§Tee
§Persist(Box<HfPlusNode>)
§Unpersist(Box<HfPlusNode>)
§Delta(Box<HfPlusNode>)
§Chain(Box<HfPlusNode>, Box<HfPlusNode>)
§CrossProduct(Box<HfPlusNode>, Box<HfPlusNode>)
§CrossSingleton(Box<HfPlusNode>, Box<HfPlusNode>)
§Join(Box<HfPlusNode>, Box<HfPlusNode>)
§Difference(Box<HfPlusNode>, Box<HfPlusNode>)
§AntiJoin(Box<HfPlusNode>, Box<HfPlusNode>)
§Map
§FlatMap
§Filter
§FilterMap
§DeferTick(Box<HfPlusNode>)
§Enumerate
§Inspect
§Unique(Box<HfPlusNode>)
§Sort(Box<HfPlusNode>)
§Fold
§FoldKeyed
§Reduce
§ReduceKeyed
§Network
Fields
§from_location: LocationId§to_location: LocationId§instantiate_fn: DebugInstantiate§input: Box<HfPlusNode>Implementations§
source§impl<'a> HfPlusNode
sourcepub fn compile_network<D: Deploy<'a>>(
+
Variants§
§Placeholder
§Source
§CycleSource
§Tee
§Persist(Box<HfPlusNode>)
§Unpersist(Box<HfPlusNode>)
§Delta(Box<HfPlusNode>)
§Chain(Box<HfPlusNode>, Box<HfPlusNode>)
§CrossProduct(Box<HfPlusNode>, Box<HfPlusNode>)
§CrossSingleton(Box<HfPlusNode>, Box<HfPlusNode>)
§Join(Box<HfPlusNode>, Box<HfPlusNode>)
§Difference(Box<HfPlusNode>, Box<HfPlusNode>)
§AntiJoin(Box<HfPlusNode>, Box<HfPlusNode>)
§Map
§FlatMap
§Filter
§FilterMap
§DeferTick(Box<HfPlusNode>)
§Enumerate
§Inspect
§Unique(Box<HfPlusNode>)
§Sort(Box<HfPlusNode>)
§Fold
§FoldKeyed
§Reduce
§ReduceKeyed
§Network
Implementations§
source§impl<'a> HfPlusNode
sourcepub fn compile_network<D: Deploy<'a>>(
&mut self,
compile_env: &D::CompileEnv,
seen_tees: &mut SeenTees,
@@ -95,7 +95,7 @@
seen_tees: &mut SeenTees,
)
sourcepub fn emit(
&self,
- graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>,
+ graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>,
built_tees: &mut HashMap<*const RefCell<HfPlusNode>, (Ident, usize)>,
next_stmt_id: &mut usize,
) -> (Ident, usize)
Trait Implementations§
Auto Trait Implementations§
§impl Freeze for HfPlusNode
§impl !RefUnwindSafe for HfPlusNode
§impl !Send for HfPlusNode
§impl !Sync for HfPlusNode
§impl Unpin for HfPlusNode
§impl !UnwindSafe for HfPlusNode
Blanket Implementations§
source§impl<T> Any for Twhere
diff --git a/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html b/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
index a5fb1a0b86c9..b70722549219 100644
--- a/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
+++ b/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
@@ -1,4 +1,4 @@
-DebugPipelineFn in hydroflow_plus::ir - Rust Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);
Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moreAuto Trait Implementations§
§impl Freeze for DebugPipelineFn
§impl !RefUnwindSafe for DebugPipelineFn
§impl !Send for DebugPipelineFn
§impl !Sync for DebugPipelineFn
§impl Unpin for DebugPipelineFn
§impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
source§impl<T> Any for Twhere
+DebugPipelineFn in hydroflow_plus::ir - Rust Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);
Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moreAuto Trait Implementations§
§impl Freeze for DebugPipelineFn
§impl !RefUnwindSafe for DebugPipelineFn
§impl !Send for DebugPipelineFn
§impl !Sync for DebugPipelineFn
§impl Unpin for DebugPipelineFn
§impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
Struct hydroflow_plus::builder::compiled::CompiledFlow
source · pub struct CompiledFlow<'a, ID> { /* private fields */ }Implementations§
source§impl<ID> CompiledFlow<'_, ID>
impl<ID> CompiledFlow<'_, ID>
pub fn hydroflow_ir(&self) -> &BTreeMap<usize, HydroflowGraph>
pub fn take_ir(self) -> BTreeMap<usize, HydroflowGraph>
source§impl<'a> CompiledFlow<'a, usize>
impl<'a> CompiledFlow<'a, usize>
pub fn with_dynamic_id( self, id: impl QuotedWithContext<'a, usize, ()>, ) -> CompiledFlowWithId<'a>
Trait Implementations§
source§impl<'a, Ctx> FreeVariableWithContext<Ctx> for CompiledFlow<'a, ()>
impl<'a, Ctx> FreeVariableWithContext<Ctx> for CompiledFlow<'a, ()>
source§impl<'a, Ctx> QuotedWithContext<'a, Hydroflow<'a>, Ctx> for CompiledFlow<'a, ()>
impl<'a, Ctx> QuotedWithContext<'a, Hydroflow<'a>, Ctx> for CompiledFlow<'a, ()>
fn splice_untyped_ctx(self, ctx: &Ctx) -> Exprwhere
diff --git a/doc/hydroflow_plus/deploy/in_memory_graph/struct.MultiNode.html b/doc/hydroflow_plus/deploy/in_memory_graph/struct.MultiNode.html
index 26584118f5b9..6b0e486ebfa8 100644
--- a/doc/hydroflow_plus/deploy/in_memory_graph/struct.MultiNode.html
+++ b/doc/hydroflow_plus/deploy/in_memory_graph/struct.MultiNode.html
@@ -2,7 +2,7 @@
&self,
_env: &mut Self::InstantiateEnv,
_meta: &mut Self::Meta,
- _graph: HydroflowGraph,
+ _graph: HydroflowGraph,
_extra_stmts: Vec<Stmt>,
)
Auto Trait Implementations§
impl Freeze for MultiNode
impl RefUnwindSafe for MultiNode
impl Send for MultiNode
impl Sync for MultiNode
impl Unpin for MultiNode
impl UnwindSafe for MultiNode
Blanket Implementations§
source§impl<T> Borrow<T> for Twhere
diff --git a/doc/hydroflow_plus/deploy/in_memory_graph/struct.SingleNode.html b/doc/hydroflow_plus/deploy/in_memory_graph/struct.SingleNode.html
index 32a0b5a0f716..466af81c388f 100644
--- a/doc/hydroflow_plus/deploy/in_memory_graph/struct.SingleNode.html
+++ b/doc/hydroflow_plus/deploy/in_memory_graph/struct.SingleNode.html
@@ -2,7 +2,7 @@
&self,
_env: &mut Self::InstantiateEnv,
_meta: &mut Self::Meta,
- _graph: HydroflowGraph,
+ _graph: HydroflowGraph,
_extra_stmts: Vec<Stmt>,
)
impl<T> Borrow<T> for Twhere
diff --git a/doc/hydroflow_plus/deploy/in_memory_graph/struct.SingleNode.html b/doc/hydroflow_plus/deploy/in_memory_graph/struct.SingleNode.html
index 32a0b5a0f716..466af81c388f 100644
--- a/doc/hydroflow_plus/deploy/in_memory_graph/struct.SingleNode.html
+++ b/doc/hydroflow_plus/deploy/in_memory_graph/struct.SingleNode.html
@@ -2,7 +2,7 @@
&self,
_env: &mut Self::InstantiateEnv,
_meta: &mut Self::Meta,
- _graph: HydroflowGraph,
+ _graph: HydroflowGraph,
_extra_stmts: Vec<Stmt>,
)
Auto Trait Implementations§
impl Freeze for SingleNode
impl RefUnwindSafe for SingleNode
impl Send for SingleNode
impl Sync for SingleNode
impl Unpin for SingleNode
impl UnwindSafe for SingleNode
Blanket Implementations§
source§impl<T> Borrow<T> for Twhere
diff --git a/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeCluster.html b/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeCluster.html
index 08e204ad51c2..d902bb327662 100644
--- a/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeCluster.html
+++ b/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeCluster.html
@@ -2,7 +2,7 @@
&self,
_env: &mut Self::InstantiateEnv,
_meta: &mut Self::Meta,
- _graph: HydroflowGraph,
+ _graph: HydroflowGraph,
_extra_stmts: Vec<Stmt>,
)
impl<T> Borrow<T> for Twhere
diff --git a/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeCluster.html b/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeCluster.html
index 08e204ad51c2..d902bb327662 100644
--- a/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeCluster.html
+++ b/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeCluster.html
@@ -2,7 +2,7 @@
&self,
_env: &mut Self::InstantiateEnv,
_meta: &mut Self::Meta,
- _graph: HydroflowGraph,
+ _graph: HydroflowGraph,
_extra_stmts: Vec<Stmt>,
)
Auto Trait Implementations§
impl Freeze for DeployRuntimeCluster
impl !RefUnwindSafe for DeployRuntimeCluster
impl !Send for DeployRuntimeCluster
impl !Sync for DeployRuntimeCluster
impl Unpin for DeployRuntimeCluster
impl !UnwindSafe for DeployRuntimeCluster
Blanket Implementations§
source§impl<T> Borrow<T> for Twhere
diff --git a/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeNode.html b/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeNode.html
index 0db9cb236779..a99bd2986d76 100644
--- a/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeNode.html
+++ b/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeNode.html
@@ -2,7 +2,7 @@
&self,
_env: &mut Self::InstantiateEnv,
_meta: &mut Self::Meta,
- _graph: HydroflowGraph,
+ _graph: HydroflowGraph,
_extra_stmts: Vec<Stmt>,
)
impl<T> Borrow<T> for Twhere
diff --git a/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeNode.html b/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeNode.html
index 0db9cb236779..a99bd2986d76 100644
--- a/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeNode.html
+++ b/doc/hydroflow_plus/deploy/macro_runtime/struct.DeployRuntimeNode.html
@@ -2,7 +2,7 @@
&self,
_env: &mut Self::InstantiateEnv,
_meta: &mut Self::Meta,
- _graph: HydroflowGraph,
+ _graph: HydroflowGraph,
_extra_stmts: Vec<Stmt>,
)
source§impl<'a> RegisterPort<'a, DeployRuntime> for DeployRuntimeNode
impl<'a> RegisterPort<'a, DeployRuntime> for DeployRuntimeNode
fn register(&self, _key: usize, _port: <DeployRuntime as Deploy<'_>>::Port)
fn raw_port(
&self,
diff --git a/doc/hydroflow_plus/deploy/trait.Node.html b/doc/hydroflow_plus/deploy/trait.Node.html
index 1443f5c5da02..6a0c02090a41 100644
--- a/doc/hydroflow_plus/deploy/trait.Node.html
+++ b/doc/hydroflow_plus/deploy/trait.Node.html
@@ -10,13 +10,13 @@
&self,
env: &mut Self::InstantiateEnv,
meta: &mut Self::Meta,
- graph: HydroflowGraph,
+ graph: HydroflowGraph,
extra_stmts: Vec<Stmt>,
);
}Required Associated Types§
Required Methods§
sourcefn next_port(&self) -> Self::Port
sourcefn update_meta(&mut self, meta: &Self::Meta)
sourcefn instantiate(
&self,
env: &mut Self::InstantiateEnv,
meta: &mut Self::Meta,
- graph: HydroflowGraph,
+ graph: HydroflowGraph,
extra_stmts: Vec<Stmt>,
)
Implementors§
fn next_port(&self) -> Self::Port
fn update_meta(&mut self, meta: &Self::Meta)
fn instantiate( &self, env: &mut Self::InstantiateEnv, meta: &mut Self::Meta, - graph: HydroflowGraph, + graph: HydroflowGraph, extra_stmts: Vec<Stmt>, )
pub fn emit( &self, - graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>, + graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>, built_tees: &mut HashMap<*const RefCell<HfPlusNode>, (Ident, usize)>, next_stmt_id: &mut usize, )
Trait Implementations§
Auto Trait Implementations§
impl Freeze for HfPlusLeaf
impl !RefUnwindSafe for HfPlusLeaf
impl !Send for HfPlusLeaf
impl !Sync for HfPlusLeaf
impl Unpin for HfPlusLeaf
impl !UnwindSafe for HfPlusLeaf
Blanket Implementations§
source§impl<T> Any for Twhere
diff --git a/doc/hydroflow_plus/ir/enum.HfPlusNode.html b/doc/hydroflow_plus/ir/enum.HfPlusNode.html
index 78e5a2a0fcb0..cc37075ae514 100644
--- a/doc/hydroflow_plus/ir/enum.HfPlusNode.html
+++ b/doc/hydroflow_plus/ir/enum.HfPlusNode.html
@@ -70,14 +70,14 @@
from_key: Option<usize>,
to_location: LocationId,
to_key: Option<usize>,
- serialize_pipeline: Option<Pipeline>,
+ serialize_pipeline: Option<Pipeline>,
instantiate_fn: DebugInstantiate,
- deserialize_pipeline: Option<Pipeline>,
+ deserialize_pipeline: Option<Pipeline>,
input: Box<HfPlusNode>,
},
}Expand description
An intermediate node in a Hydroflow+ graph, which consumes data
from upstream nodes and emits data to downstream nodes.
-Variants§
§Placeholder
§Source
§CycleSource
§Tee
§Persist(Box<HfPlusNode>)
§Unpersist(Box<HfPlusNode>)
§Delta(Box<HfPlusNode>)
§Chain(Box<HfPlusNode>, Box<HfPlusNode>)
§CrossProduct(Box<HfPlusNode>, Box<HfPlusNode>)
§CrossSingleton(Box<HfPlusNode>, Box<HfPlusNode>)
§Join(Box<HfPlusNode>, Box<HfPlusNode>)
§Difference(Box<HfPlusNode>, Box<HfPlusNode>)
§AntiJoin(Box<HfPlusNode>, Box<HfPlusNode>)
§Map
§FlatMap
§Filter
§FilterMap
§DeferTick(Box<HfPlusNode>)
§Enumerate
§Inspect
§Unique(Box<HfPlusNode>)
§Sort(Box<HfPlusNode>)
§Fold
§FoldKeyed
§Reduce
§ReduceKeyed
§Network
Fields
§from_location: LocationId§to_location: LocationId§instantiate_fn: DebugInstantiate§input: Box<HfPlusNode>Implementations§
source§impl<'a> HfPlusNode
sourcepub fn compile_network<D: Deploy<'a>>(
+
Variants§
§Placeholder
§Source
§CycleSource
§Tee
§Persist(Box<HfPlusNode>)
§Unpersist(Box<HfPlusNode>)
§Delta(Box<HfPlusNode>)
§Chain(Box<HfPlusNode>, Box<HfPlusNode>)
§CrossProduct(Box<HfPlusNode>, Box<HfPlusNode>)
§CrossSingleton(Box<HfPlusNode>, Box<HfPlusNode>)
§Join(Box<HfPlusNode>, Box<HfPlusNode>)
§Difference(Box<HfPlusNode>, Box<HfPlusNode>)
§AntiJoin(Box<HfPlusNode>, Box<HfPlusNode>)
§Map
§FlatMap
§Filter
§FilterMap
§DeferTick(Box<HfPlusNode>)
§Enumerate
§Inspect
§Unique(Box<HfPlusNode>)
§Sort(Box<HfPlusNode>)
§Fold
§FoldKeyed
§Reduce
§ReduceKeyed
§Network
Implementations§
source§impl<'a> HfPlusNode
sourcepub fn compile_network<D: Deploy<'a>>(
&mut self,
compile_env: &D::CompileEnv,
seen_tees: &mut SeenTees,
@@ -95,7 +95,7 @@
seen_tees: &mut SeenTees,
)
sourcepub fn emit(
&self,
- graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>,
+ graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>,
built_tees: &mut HashMap<*const RefCell<HfPlusNode>, (Ident, usize)>,
next_stmt_id: &mut usize,
) -> (Ident, usize)
Trait Implementations§
Auto Trait Implementations§
§impl Freeze for HfPlusNode
§impl !RefUnwindSafe for HfPlusNode
§impl !Send for HfPlusNode
§impl !Sync for HfPlusNode
§impl Unpin for HfPlusNode
§impl !UnwindSafe for HfPlusNode
Blanket Implementations§
source§impl<T> Any for Twhere
diff --git a/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html b/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
index a5fb1a0b86c9..b70722549219 100644
--- a/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
+++ b/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
@@ -1,4 +1,4 @@
-DebugPipelineFn in hydroflow_plus::ir - Rust Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);
Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moreAuto Trait Implementations§
§impl Freeze for DebugPipelineFn
§impl !RefUnwindSafe for DebugPipelineFn
§impl !Send for DebugPipelineFn
§impl !Sync for DebugPipelineFn
§impl Unpin for DebugPipelineFn
§impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
source§impl<T> Any for Twhere
+DebugPipelineFn in hydroflow_plus::ir - Rust Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);
Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moreAuto Trait Implementations§
§impl Freeze for DebugPipelineFn
§impl !RefUnwindSafe for DebugPipelineFn
§impl !Send for DebugPipelineFn
§impl !Sync for DebugPipelineFn
§impl Unpin for DebugPipelineFn
§impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
impl<T> Any for Twhere
diff --git a/doc/hydroflow_plus/ir/enum.HfPlusNode.html b/doc/hydroflow_plus/ir/enum.HfPlusNode.html
index 78e5a2a0fcb0..cc37075ae514 100644
--- a/doc/hydroflow_plus/ir/enum.HfPlusNode.html
+++ b/doc/hydroflow_plus/ir/enum.HfPlusNode.html
@@ -70,14 +70,14 @@
from_key: Option<usize>,
to_location: LocationId,
to_key: Option<usize>,
- serialize_pipeline: Option<Pipeline>,
+ serialize_pipeline: Option<Pipeline>,
instantiate_fn: DebugInstantiate,
- deserialize_pipeline: Option<Pipeline>,
+ deserialize_pipeline: Option<Pipeline>,
input: Box<HfPlusNode>,
},
}Expand description
An intermediate node in a Hydroflow+ graph, which consumes data
from upstream nodes and emits data to downstream nodes.
-Variants§
§Placeholder
§Source
§CycleSource
§Tee
§Persist(Box<HfPlusNode>)
§Unpersist(Box<HfPlusNode>)
§Delta(Box<HfPlusNode>)
§Chain(Box<HfPlusNode>, Box<HfPlusNode>)
§CrossProduct(Box<HfPlusNode>, Box<HfPlusNode>)
§CrossSingleton(Box<HfPlusNode>, Box<HfPlusNode>)
§Join(Box<HfPlusNode>, Box<HfPlusNode>)
§Difference(Box<HfPlusNode>, Box<HfPlusNode>)
§AntiJoin(Box<HfPlusNode>, Box<HfPlusNode>)
§Map
§FlatMap
§Filter
§FilterMap
§DeferTick(Box<HfPlusNode>)
§Enumerate
§Inspect
§Unique(Box<HfPlusNode>)
§Sort(Box<HfPlusNode>)
§Fold
§FoldKeyed
§Reduce
§ReduceKeyed
§Network
Fields
§from_location: LocationId§to_location: LocationId§instantiate_fn: DebugInstantiate§input: Box<HfPlusNode>Implementations§
source§impl<'a> HfPlusNode
sourcepub fn compile_network<D: Deploy<'a>>(
+
Variants§
§Placeholder
§Source
§CycleSource
§Tee
§Persist(Box<HfPlusNode>)
§Unpersist(Box<HfPlusNode>)
§Delta(Box<HfPlusNode>)
§Chain(Box<HfPlusNode>, Box<HfPlusNode>)
§CrossProduct(Box<HfPlusNode>, Box<HfPlusNode>)
§CrossSingleton(Box<HfPlusNode>, Box<HfPlusNode>)
§Join(Box<HfPlusNode>, Box<HfPlusNode>)
§Difference(Box<HfPlusNode>, Box<HfPlusNode>)
§AntiJoin(Box<HfPlusNode>, Box<HfPlusNode>)
§Map
§FlatMap
§Filter
§FilterMap
§DeferTick(Box<HfPlusNode>)
§Enumerate
§Inspect
§Unique(Box<HfPlusNode>)
§Sort(Box<HfPlusNode>)
§Fold
§FoldKeyed
§Reduce
§ReduceKeyed
§Network
Implementations§
source§impl<'a> HfPlusNode
sourcepub fn compile_network<D: Deploy<'a>>(
&mut self,
compile_env: &D::CompileEnv,
seen_tees: &mut SeenTees,
@@ -95,7 +95,7 @@
seen_tees: &mut SeenTees,
)
sourcepub fn emit(
&self,
- graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>,
+ graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>,
built_tees: &mut HashMap<*const RefCell<HfPlusNode>, (Ident, usize)>,
next_stmt_id: &mut usize,
) -> (Ident, usize)
Trait Implementations§
Auto Trait Implementations§
§impl Freeze for HfPlusNode
§impl !RefUnwindSafe for HfPlusNode
§impl !Send for HfPlusNode
§impl !Sync for HfPlusNode
§impl Unpin for HfPlusNode
§impl !UnwindSafe for HfPlusNode
Blanket Implementations§
source§impl<T> Any for Twhere
diff --git a/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html b/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
index a5fb1a0b86c9..b70722549219 100644
--- a/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
+++ b/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
@@ -1,4 +1,4 @@
-DebugPipelineFn in hydroflow_plus::ir - Rust Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);
Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moreAuto Trait Implementations§
§impl Freeze for DebugPipelineFn
§impl !RefUnwindSafe for DebugPipelineFn
§impl !Send for DebugPipelineFn
§impl !Sync for DebugPipelineFn
§impl Unpin for DebugPipelineFn
§impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
source§impl<T> Any for Twhere
+DebugPipelineFn in hydroflow_plus::ir - Rust Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);
Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moreAuto Trait Implementations§
§impl Freeze for DebugPipelineFn
§impl !RefUnwindSafe for DebugPipelineFn
§impl !Send for DebugPipelineFn
§impl !Sync for DebugPipelineFn
§impl Unpin for DebugPipelineFn
§impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
Expand description
An intermediate node in a Hydroflow+ graph, which consumes data from upstream nodes and emits data to downstream nodes.
-Variants§
Placeholder
Source
CycleSource
Tee
Persist(Box<HfPlusNode>)
Unpersist(Box<HfPlusNode>)
Delta(Box<HfPlusNode>)
Chain(Box<HfPlusNode>, Box<HfPlusNode>)
CrossProduct(Box<HfPlusNode>, Box<HfPlusNode>)
CrossSingleton(Box<HfPlusNode>, Box<HfPlusNode>)
Join(Box<HfPlusNode>, Box<HfPlusNode>)
Difference(Box<HfPlusNode>, Box<HfPlusNode>)
AntiJoin(Box<HfPlusNode>, Box<HfPlusNode>)
Map
FlatMap
Filter
FilterMap
DeferTick(Box<HfPlusNode>)
Enumerate
Inspect
Unique(Box<HfPlusNode>)
Sort(Box<HfPlusNode>)
Fold
FoldKeyed
Reduce
ReduceKeyed
Network
Fields
§
from_location: LocationId§
to_location: LocationId§
instantiate_fn: DebugInstantiate§
input: Box<HfPlusNode>Implementations§
source§impl<'a> HfPlusNode
impl<'a> HfPlusNode
pub fn compile_network<D: Deploy<'a>>( +
Variants§
Placeholder
Source
CycleSource
Tee
Persist(Box<HfPlusNode>)
Unpersist(Box<HfPlusNode>)
Delta(Box<HfPlusNode>)
Chain(Box<HfPlusNode>, Box<HfPlusNode>)
CrossProduct(Box<HfPlusNode>, Box<HfPlusNode>)
CrossSingleton(Box<HfPlusNode>, Box<HfPlusNode>)
Join(Box<HfPlusNode>, Box<HfPlusNode>)
Difference(Box<HfPlusNode>, Box<HfPlusNode>)
AntiJoin(Box<HfPlusNode>, Box<HfPlusNode>)
Map
FlatMap
Filter
FilterMap
DeferTick(Box<HfPlusNode>)
Enumerate
Inspect
Unique(Box<HfPlusNode>)
Sort(Box<HfPlusNode>)
Fold
FoldKeyed
Reduce
ReduceKeyed
Network
Implementations§
source§impl<'a> HfPlusNode
impl<'a> HfPlusNode
pub fn compile_network<D: Deploy<'a>>( &mut self, compile_env: &D::CompileEnv, seen_tees: &mut SeenTees, @@ -95,7 +95,7 @@ seen_tees: &mut SeenTees, )
pub fn emit( &self, - graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>, + graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>, built_tees: &mut HashMap<*const RefCell<HfPlusNode>, (Ident, usize)>, next_stmt_id: &mut usize, ) -> (Ident, usize)
Trait Implementations§
Auto Trait Implementations§
impl Freeze for HfPlusNode
impl !RefUnwindSafe for HfPlusNode
impl !Send for HfPlusNode
impl !Sync for HfPlusNode
impl Unpin for HfPlusNode
impl !UnwindSafe for HfPlusNode
Blanket Implementations§
source§impl<T> Any for Twhere
diff --git a/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html b/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
index a5fb1a0b86c9..b70722549219 100644
--- a/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
+++ b/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
@@ -1,4 +1,4 @@
-DebugPipelineFn in hydroflow_plus::ir - Rust Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);
Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moreAuto Trait Implementations§
§impl Freeze for DebugPipelineFn
§impl !RefUnwindSafe for DebugPipelineFn
§impl !Send for DebugPipelineFn
§impl !Sync for DebugPipelineFn
§impl Unpin for DebugPipelineFn
§impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
source§impl<T> Any for Twhere
+DebugPipelineFn in hydroflow_plus::ir - Rust Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);
Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moreAuto Trait Implementations§
§impl Freeze for DebugPipelineFn
§impl !RefUnwindSafe for DebugPipelineFn
§impl !Send for DebugPipelineFn
§impl !Sync for DebugPipelineFn
§impl Unpin for DebugPipelineFn
§impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
impl<T> Any for Twhere
diff --git a/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html b/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
index a5fb1a0b86c9..b70722549219 100644
--- a/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
+++ b/doc/hydroflow_plus/ir/struct.DebugPipelineFn.html
@@ -1,4 +1,4 @@
-DebugPipelineFn in hydroflow_plus::ir - Rust Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);
Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moreAuto Trait Implementations§
§impl Freeze for DebugPipelineFn
§impl !RefUnwindSafe for DebugPipelineFn
§impl !Send for DebugPipelineFn
§impl !Sync for DebugPipelineFn
§impl Unpin for DebugPipelineFn
§impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
source§impl<T> Any for Twhere
+DebugPipelineFn in hydroflow_plus::ir - Rust Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);
Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moreAuto Trait Implementations§
§impl Freeze for DebugPipelineFn
§impl !RefUnwindSafe for DebugPipelineFn
§impl !Send for DebugPipelineFn
§impl !Sync for DebugPipelineFn
§impl Unpin for DebugPipelineFn
§impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for DebugPipelineFn
impl !RefUnwindSafe for DebugPipelineFn
impl !Send for DebugPipelineFn
impl !Sync for DebugPipelineFn
impl Unpin for DebugPipelineFn
impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
source§impl<T> Any for Twhere
+DebugPipelineFn in hydroflow_plus::ir - Rust Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);
Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moreAuto Trait Implementations§
§impl Freeze for DebugPipelineFn
§impl !RefUnwindSafe for DebugPipelineFn
§impl !Send for DebugPipelineFn
§impl !Sync for DebugPipelineFn
§impl Unpin for DebugPipelineFn
§impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
impl<T> Any for Twhere
+DebugPipelineFn in hydroflow_plus::ir - Rust Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);
Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moreAuto Trait Implementations§
§impl Freeze for DebugPipelineFn
§impl !RefUnwindSafe for DebugPipelineFn
§impl !Send for DebugPipelineFn
§impl !Sync for DebugPipelineFn
§impl Unpin for DebugPipelineFn
§impl !UnwindSafe for DebugPipelineFn
Blanket Implementations§
Struct hydroflow_plus::ir::DebugPipelineFn
source · pub struct DebugPipelineFn(pub Rc<dyn Fn() -> Pipeline + 'static>);Tuple Fields§
§0: Rc<dyn Fn() -> Pipeline + 'static>Trait Implementations§
source§impl Clone for DebugPipelineFn
impl Clone for DebugPipelineFn
source§fn clone(&self) -> DebugPipelineFn
fn clone(&self) -> DebugPipelineFn
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read more