pub enum StreamComponent {
Show 14 variants
ForEach {
class_name: String,
},
ForEachIncludingUnassigned {
class_name: String,
},
ForEachUniquePair {
class_name: String,
joiners: Vec<Joiner>,
},
Filter {
predicate: WasmFunction,
},
Join {
class_name: String,
joiners: Vec<Joiner>,
},
IfExists {
class_name: String,
joiners: Vec<Joiner>,
},
IfNotExists {
class_name: String,
joiners: Vec<Joiner>,
},
GroupBy {
keys: Vec<WasmFunction>,
aggregators: Vec<Collector>,
},
Map {
mappers: Vec<WasmFunction>,
},
FlattenLast {
map: Option<WasmFunction>,
},
Expand {
mappers: Vec<WasmFunction>,
},
Complement {
class_name: String,
},
Penalize {
weight: String,
scale_by: Option<WasmFunction>,
},
Reward {
weight: String,
scale_by: Option<WasmFunction>,
},
}Variants§
ForEach
ForEachIncludingUnassigned
ForEachUniquePair
Filter
Fields
§
predicate: WasmFunctionJoin
IfExists
IfNotExists
GroupBy
Map
Fields
§
mappers: Vec<WasmFunction>FlattenLast
Fields
§
map: Option<WasmFunction>Expand
Fields
§
mappers: Vec<WasmFunction>Complement
Penalize
Reward
Implementations§
Source§impl StreamComponent
impl StreamComponent
pub fn for_each(class_name: impl Into<String>) -> Self
pub fn for_each_including_unassigned(class_name: impl Into<String>) -> Self
pub fn for_each_unique_pair(class_name: impl Into<String>) -> Self
pub fn for_each_unique_pair_with_joiners( class_name: impl Into<String>, joiners: Vec<Joiner>, ) -> Self
pub fn filter(predicate: WasmFunction) -> Self
pub fn join(class_name: impl Into<String>) -> Self
pub fn join_with_joiners( class_name: impl Into<String>, joiners: Vec<Joiner>, ) -> Self
pub fn if_exists(class_name: impl Into<String>) -> Self
pub fn if_exists_with_joiners( class_name: impl Into<String>, joiners: Vec<Joiner>, ) -> Self
pub fn if_not_exists(class_name: impl Into<String>) -> Self
pub fn if_not_exists_with_joiners( class_name: impl Into<String>, joiners: Vec<Joiner>, ) -> Self
pub fn group_by(keys: Vec<WasmFunction>, aggregators: Vec<Collector>) -> Self
pub fn group_by_key(key: WasmFunction) -> Self
pub fn group_by_collector(aggregator: Collector) -> Self
pub fn map(mappers: Vec<WasmFunction>) -> Self
pub fn map_single(mapper: WasmFunction) -> Self
pub fn flatten_last() -> Self
pub fn flatten_last_with_map(map: WasmFunction) -> Self
pub fn expand(mappers: Vec<WasmFunction>) -> Self
pub fn complement(class_name: impl Into<String>) -> Self
pub fn penalize(weight: impl Into<String>) -> Self
pub fn penalize_with_weigher( weight: impl Into<String>, scale_by: WasmFunction, ) -> Self
pub fn reward(weight: impl Into<String>) -> Self
pub fn reward_with_weigher( weight: impl Into<String>, scale_by: WasmFunction, ) -> Self
Trait Implementations§
Source§impl Clone for StreamComponent
impl Clone for StreamComponent
Source§fn clone(&self) -> StreamComponent
fn clone(&self) -> StreamComponent
Returns a duplicate of the value. Read more
1.0.0§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for StreamComponent
impl Debug for StreamComponent
Source§impl<'de> Deserialize<'de> for StreamComponent
impl<'de> Deserialize<'de> for StreamComponent
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl PartialEq for StreamComponent
impl PartialEq for StreamComponent
Source§impl Serialize for StreamComponent
impl Serialize for StreamComponent
impl Eq for StreamComponent
impl StructuralPartialEq for StreamComponent
Auto Trait Implementations§
impl Freeze for StreamComponent
impl RefUnwindSafe for StreamComponent
impl Send for StreamComponent
impl Sync for StreamComponent
impl Unpin for StreamComponent
impl UnwindSafe for StreamComponent
Blanket Implementations§
§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§unsafe fn clone_to_uninit(&self, dest: *mut u8)
unsafe fn clone_to_uninit(&self, dest: *mut u8)
🔬This is a nightly-only experimental API. (
clone_to_uninit)Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.