File tree Expand file tree Collapse file tree 1 file changed +6
-0
lines changed
timely/src/dataflow/operators/generic Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Original file line number Diff line number Diff line change @@ -19,6 +19,7 @@ use crate::dataflow::channels::pullers::Counter as PullCounter;
1919use crate :: dataflow:: operators:: capability:: Capability ;
2020use crate :: dataflow:: operators:: generic:: handles:: { InputHandle , new_input_handle, OutputWrapper } ;
2121use crate :: dataflow:: operators:: generic:: operator_info:: OperatorInfo ;
22+ use crate :: dataflow:: operators:: generic:: builder_raw:: OperatorShape ;
2223
2324use crate :: logging:: TimelyLogger as Logger ;
2425
@@ -193,6 +194,11 @@ impl<G: Scope> OperatorBuilder<G> {
193194 self . builder . global ( )
194195 }
195196
197+ /// Return a reference to the operator's shape
198+ pub fn shape ( & self ) -> & OperatorShape {
199+ self . builder . shape ( )
200+ }
201+
196202 /// Creates operator info for the operator.
197203 pub fn operator_info ( & self ) -> OperatorInfo {
198204 self . builder . operator_info ( )
You can’t perform that action at this time.
0 commit comments