sdf_metadata/util/
operator_placement.rs

1use serde::{Serialize, Deserialize};
2
3/// Describes where an operator is in a dataflow for add, edit, remove
4/// transforms index must be provided if window and partition are false
5///
6/// if window or partition is true, and transforms index is None,
7/// then the OperatorPlacement is referring to the assign_timestamp or assign_key operator
8/// respectively
9///
10/// if window and partition are true, the OperatorPlacement is referring to the
11/// partition inside the window
12#[derive(Debug, Default, Serialize, Deserialize, Clone, PartialEq, Eq)]
13pub struct OperatorPlacement {
14    pub service_id: String,
15    pub window: bool,
16    pub partition: bool,
17    pub transforms_index: Option<usize>,
18}