timely/dataflow/operators/generic/
operator_info.rs

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