Extract internal cache data (``_meta``) from dd.DataFrame / dd.Series
(x, nonempty=False)
| 4127 | |
| 4128 | |
| 4129 | def _extract_meta(x, nonempty=False): |
| 4130 | """ |
| 4131 | Extract internal cache data (``_meta``) from dd.DataFrame / dd.Series |
| 4132 | """ |
| 4133 | if isinstance(x, Expr): |
| 4134 | return meta_nonempty(x._meta) if nonempty else x._meta |
| 4135 | elif isinstance(x, list): |
| 4136 | return [_extract_meta(_x, nonempty) for _x in x] |
| 4137 | elif isinstance(x, tuple): |
| 4138 | return tuple(_extract_meta(_x, nonempty) for _x in x) |
| 4139 | elif isinstance(x, dict): |
| 4140 | res = {} |
| 4141 | for k in x: |
| 4142 | res[k] = _extract_meta(x[k], nonempty) |
| 4143 | return res |
| 4144 | elif hasattr(x, "expr"): |
| 4145 | return _extract_meta(x.expr, nonempty) |
| 4146 | else: |
| 4147 | return x |
| 4148 | |
| 4149 | |
| 4150 | def emulate(func, *args, udf=False, **kwargs): |
no outgoing calls
no test coverage detected