Enum StreamAccessKind

pub enum StreamAccessKind {
    Sync,
    DiscreteWindow(WindowReference),
    SlidingWindow(WindowReference),
    InstanceAggregation(WindowReference),
    Hold,
    Offset(Offset),
    Get,
    Fresh,
}

Representation of the different stream accesses

Variants

Sync

Represents the synchronous access

DiscreteWindow(WindowReference)

Represents the access to a (discrete window)DiscreteWindow

The argument contains the reference to the (discrete window)DiscreteWindow whose value is used in the Expression.

SlidingWindow(WindowReference)

Represents the access to a (sliding window)SlidingWindow

The argument contains the reference to the (sliding window)SlidingWindow whose value is used in the Expression.

InstanceAggregation(WindowReference)

Represents the access to a (instance aggregation)InstanceAggregation

The argument contains the reference to the (instance aggregation)InstanceAggregation whose value is used in the Expression.

Hold

Representation of sample and hold accesses

Offset(Offset)

Representation of offset accesses

The argument contains the Offset of the stream access.

Get

Represents the optional get access.

Fresh

Represents the update check of a stream, if the target received a new value at this timestamp.

Trait Implementations

impl Clone for StreamAccessKind

fn clone(&self) -> StreamAccessKind

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamAccessKind

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamAccessKind

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Hash for StreamAccessKind

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for StreamAccessKind

fn eq(&self, other: &StreamAccessKind) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for StreamAccessKind

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for StreamAccessKind

impl Eq for StreamAccessKind

impl StructuralPartialEq for StreamAccessKind