

@append.register(Collection, Iterator)
def append_iterator_to_pymongo(coll, seq, columns=None, dshape=None, chunksize=1024, **kwargs):
    seq = iter(seq)
    item = next(seq)
    seq = concat([[item], seq])
    if isinstance(item, (tuple, list)):
        if ((not kwargs) and dshape):
            columns = dshape.measure.names
        if (not columns):
            raise ValueError('Inputs must be dictionaries. Or provide columns=[...] or dshape=DataShape(...) keyword')
        seq = (dict(zip(columns, item)) for item in seq)
    for block in partition_all(1024, seq):
        coll.insert(copy.deepcopy(block))
    return coll

dataset/ETHPy150Open blaze/odo/odo/backends/mongo.py append_iterator_to_pymongo/VarMisuse@82/90 `columns`->`kwargs`