bi<ddlmZddlmZddlmZddlmZddZy)) annotations) FrameBase) _df_to_bag)tokenizec ddlm}|j}t|ts t ddt |j||z}|dk(r|j}|j}nUt|jDcic]\}}||ft|||f}}}|j|j||||jScc}}w)a1Create Dask Bag from a Dask DataFrame Parameters ---------- index : bool, optional If True, the elements are tuples of ``(index, value)``, otherwise they're just the ``value``. Default is False. format : {"tuple", "dict", "frame"}, optional Whether to return a bag of tuples, dictionaries, or dataframe-like objects. Default is "tuple". If "frame", the original partitions of ``df`` will not be transformed in any way. Examples -------- >>> bag = df.to_bag() # doctest: +SKIP r)Bagz%df must be either DataFrame or Serieszto_bag-frame) dask.bag.coreroptimize isinstancer TypeErrorr_namedask enumerate __dask_keys__rupdate__dask_graph__ npartitions)dfindexformatrnamedskiblocks Z/home/cdr/jupyterlab/.venv/lib/python3.12/site-packages/dask/dataframe/dask_expr/io/bag.pyto_bagrs&" B b) $?@@ x%8 8D ggxx((8(8(:; E1I E5&9 9   2$$&' sD".. ))  sCN)Ftuple) __future__rdask.dataframe.dask_exprrdask.dataframe.io.ior dask.tokenizerrrr%s".+"#*r$