pub(super) fn extract_executor_infos(
adjacency_list: &HashMap<GlobalOperatorId, StreamNode>,
) -> (HashSet<ExecutorId>, HashMap<GlobalOperatorId, HashSet<ExecutorId>>)pub(super) fn extract_executor_infos(
adjacency_list: &HashMap<GlobalOperatorId, StreamNode>,
) -> (HashSet<ExecutorId>, HashMap<GlobalOperatorId, HashSet<ExecutorId>>)