1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
/// Information about the operator being constructed #[derive(Clone)] pub struct OperatorInfo { /// Scope-local index assigned to the operator being constructed. pub local_id: usize, /// Worker-unique identifier. pub global_id: usize, /// Operator address. pub address: Vec<usize>, } impl OperatorInfo { /// Construct a new `OperatorInfo`. pub fn new(local_id: usize, global_id: usize, address: &[usize]) -> OperatorInfo { OperatorInfo { local_id, global_id, address: address.to_vec(), } } }