Enum OperatorDef 

pub enum OperatorDef {
    SourceInlineData {},
    SourceTable {
        table: TableId,
        time_domain: TimeDomain,
    },
    SourceView {
        view: ViewId,
    },
    SourceRingBuffer {
        ringbuffer: RingBufferId,
        time_domain: TimeDomain,
    },
    SourceSeries {
        series: SeriesId,
        time_domain: TimeDomain,
    },
    Filter {
        conditions: Vec<Expression>,
    },
    Gate {
        conditions: Vec<Expression>,
    },
    Map {
        expressions: Vec<Expression>,
    },
    Extend {
        expressions: Vec<Expression>,
    },
    Join {
        join_type: JoinType,
        left: Vec<Expression>,
        right: Vec<Expression>,
        alias: Option<String>,
        natural: bool,
        with: JoinWith,
    },
    Aggregate {
        by: Vec<Expression>,
        map: Vec<Expression>,
        with: AggregateWith,
    },
    Append {},
    Sort {
        by: Vec<SortKey>,
    },
    Take {
        limit: usize,
    },
    Distinct {
        expressions: Vec<Expression>,
        with: DistinctWith,
    },
    Apply {
        operator: String,
        params: Vec<Expression>,
        with: ApplyWith,
    },
    SinkTableView {
        view: ViewId,
    },
    SinkRingBufferView {
        view: ViewId,
        capacity: u64,
    },
    SinkSeriesView {
        view: ViewId,
        key: SeriesKey,
    },
    SinkSubscription {
        subscription: SubscriptionId,
    },
    Window {
        group_by: Vec<Expression>,
        aggregations: Vec<Expression>,
        with: WindowWith,
    },
    Lookup {
        join_type: JoinType,
        right: LookupObject,
        left: Vec<Expression>,
        alias: Option<String>,
        with: LookupWith,
    },
}

Variants

SourceInlineData

SourceTable

Fields

table: TableId

time_domain: TimeDomain

SourceView

Fields

view: ViewId

SourceRingBuffer

Fields

ringbuffer: RingBufferId

time_domain: TimeDomain

SourceSeries

Fields

series: SeriesId

time_domain: TimeDomain

Filter

Fields

conditions: Vec<Expression>

Gate

Fields

conditions: Vec<Expression>

Map

Fields

expressions: Vec<Expression>

Extend

Fields

expressions: Vec<Expression>

Join

Fields

join_type: JoinType

left: Vec<Expression>

right: Vec<Expression>

alias: Option<String>

natural: bool

with: JoinWith

Aggregate

Fields

by: Vec<Expression>

map: Vec<Expression>

with: AggregateWith

Append

Sort

Fields

by: Vec<SortKey>

Take

Fields

limit: usize

Distinct

Fields

expressions: Vec<Expression>

with: DistinctWith

Apply

Fields

operator: String

params: Vec<Expression>

with: ApplyWith

SinkTableView

Fields

view: ViewId

SinkRingBufferView

Fields

view: ViewId

capacity: u64

SinkSeriesView

Fields

view: ViewId

key: SeriesKey

SinkSubscription

Fields

subscription: SubscriptionId

Window

Fields

group_by: Vec<Expression>

aggregations: Vec<Expression>

with: WindowWith

Lookup

Fields

join_type: JoinType

right: LookupObject

left: Vec<Expression>

alias: Option<String>

with: LookupWith

Implementations

impl OperatorDef

pub fn is_source(&self) -> bool

pub fn declares_time(&self) -> bool

pub fn ticks(&self) -> bool

pub fn label(&self) -> String

pub fn discriminator(&self) -> u8

pub fn source_object_id(&self) -> Option<ObjectId>

Trait Implementations

impl Clone for OperatorDef

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OperatorDef

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OperatorDef

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for OperatorDef

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for OperatorDef

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for OperatorDef