Function create_aggregate_input 

pub fn create_aggregate_input(
    sources: &[&Input],
    aggregate_id: InputId,
) -> Option<AggregateDescriptor>

Create an aggregate input from multiple coalesced inputs.