def cdx_load(sources, query, process=True):
    cdx_iter = create_merged_cdx_gen(sources, query)
    if query.page_count:
        return cdx_iter
    cdx_iter = make_obj_iter(cdx_iter, query)
    if process and not query.secondary_index_only:
        cdx_iter = process_cdx(cdx_iter, query)
    custom_ops = query.custom_ops
    for op in custom_ops:
        cdx_iter = op(cdx_iter, query)
    if query.output == 'text':
        cdx_iter = cdx_to_text(cdx_iter, query.fields)
    elif query.output == 'json':
        cdx_iter = cdx_to_json(cdx_iter, query.fields)
    return cdx_iter