pub(super) fn plan_fixed_strategy(
session: &SessionImpl,
orders: Vec<(ObjectName, ObjectName)>,
plan: StreamPlanRef,
) -> Result<HashMap<u32, Uint32Vector>>pub(super) fn plan_fixed_strategy(
session: &SessionImpl,
orders: Vec<(ObjectName, ObjectName)>,
plan: StreamPlanRef,
) -> Result<HashMap<u32, Uint32Vector>>