def pipe_fetchdata(context=None, _INPUT=None, conf=None, **kwargs):
    funcs = get_splits(None, conf, **cdicts(opts, kwargs))
    parsed = get_parsed(_INPUT, funcs[0])
    results = starmap(parse_result, parsed)
    items = imap(utils.gen_items, results)
    _OUTPUT = utils.multiplex(items)
    return _OUTPUT