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