Struct OperatorPlacement 

pub struct OperatorPlacement {
    pub service_id: String,
    pub window: bool,
    pub partition: bool,
    pub transforms_index: Option<usize>,
}

Describes where an operator is in a dataflow for add, edit, remove transforms index must be provided if window and partition are false

if window or partition is true, and transforms index is None, then the OperatorPlacement is referring to the assign_timestamp or assign_key operator respectively

if window and partition are true, the OperatorPlacement is referring to the partition inside the window

Fields

service_id: String

window: bool

partition: bool

transforms_index: Option<usize>

Trait Implementations

impl Clone for OperatorPlacement

fn clone(&self) -> OperatorPlacement

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OperatorPlacement

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

Formats the value using the given formatter.

impl Default for OperatorPlacement

fn default() -> OperatorPlacement

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for OperatorPlacement

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for OperatorPlacement

fn eq(&self, other: &OperatorPlacement) -> 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 OperatorPlacement

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for OperatorPlacement

impl StructuralPartialEq for OperatorPlacement