(cls, stream_map)
| 177 | |
| 178 | @classmethod |
| 179 | def __get_incoming_edge_map(cls, stream_map): |
| 180 | incoming_edge_map = {} |
| 181 | for downstream_label, upstream in list(stream_map.items()): |
| 182 | incoming_edge_map[downstream_label] = ( |
| 183 | upstream.node, |
| 184 | upstream.label, |
| 185 | upstream.selector, |
| 186 | ) |
| 187 | return incoming_edge_map |
| 188 | |
| 189 | def __init__( |
| 190 | self, |