Struct rtlola_frontend::mir::InputStream
source · pub struct InputStream {
pub name: String,
pub ty: Type,
pub accessed_by: Vec<(StreamReference, Vec<StreamAccessKind>)>,
pub aggregated_by: Vec<(StreamReference, WindowReference)>,
pub layer: StreamLayers,
pub memory_bound: MemorizationBound,
pub reference: StreamReference,
}
Expand description
Contains all information inherent to an input stream.
Fields§
§name: String
The name of the stream
ty: Type
The value type of the stream. Note that its pacing is always pre-determined.
accessed_by: Vec<(StreamReference, Vec<StreamAccessKind>)>
The collection of streams that access the current stream non-transitively
aggregated_by: Vec<(StreamReference, WindowReference)>
The collection of sliding windows that access this stream non-transitively. This includes both sliding and discrete windows.
layer: StreamLayers
Provides the evaluation of layer of this stream.
memory_bound: MemorizationBound
Provides the number of values of this stream’s type that need to be memorized. Refer to Type::size to get a type’s byte-size.
reference: StreamReference
The reference referring to this stream
Trait Implementations§
source§impl Clone for InputStream
impl Clone for InputStream
source§fn clone(&self) -> InputStream
fn clone(&self) -> InputStream
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 moresource§impl Debug for InputStream
impl Debug for InputStream
source§impl<'de> Deserialize<'de> for InputStream
impl<'de> Deserialize<'de> for InputStream
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 Display for InputStream
impl Display for InputStream
source§impl PartialEq<InputStream> for InputStream
impl PartialEq<InputStream> for InputStream
source§fn eq(&self, other: &InputStream) -> bool
fn eq(&self, other: &InputStream) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.source§impl Serialize for InputStream
impl Serialize for InputStream
source§impl Stream for InputStream
impl Stream for InputStream
source§fn spawn_layer(&self) -> Layer
fn spawn_layer(&self) -> Layer
Reports the evaluation layer of the spawn condition of the stream.
source§fn eval_layer(&self) -> Layer
fn eval_layer(&self) -> Layer
Reports the evaluation layer of the stream.
source§fn is_parameterized(&self) -> bool
fn is_parameterized(&self) -> bool
Indicates whether or not the stream has parameters.
source§fn is_spawned(&self) -> bool
fn is_spawned(&self) -> bool
Indicates whether or not the stream spawned / dynamically created.
source§fn values_to_memorize(&self) -> MemorizationBound
fn values_to_memorize(&self) -> MemorizationBound
Indicates how many values of the stream’s Type need to be memorized.
source§fn as_stream_ref(&self) -> StreamReference
fn as_stream_ref(&self) -> StreamReference
Produces a stream references referring to the stream.
impl Eq for InputStream
impl StructuralEq for InputStream
impl StructuralPartialEq for InputStream
Auto Trait Implementations§
impl RefUnwindSafe for InputStream
impl Send for InputStream
impl Sync for InputStream
impl Unpin for InputStream
impl UnwindSafe for InputStream
Blanket Implementations§
source§impl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
impl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.