Extract internal cache data (``_meta``) from dd.DataFrame / dd.Series
(x, nonempty=False)
| 4083 | |
| 4084 | |
| 4085 | def _extract_meta(x, nonempty=False): |
| 4086 | """ |
| 4087 | Extract internal cache data (``_meta``) from dd.DataFrame / dd.Series |
| 4088 | """ |
| 4089 | if isinstance(x, Expr): |
| 4090 | return meta_nonempty(x._meta) if nonempty else x._meta |
| 4091 | elif isinstance(x, list): |
| 4092 | return [_extract_meta(_x, nonempty) for _x in x] |
| 4093 | elif isinstance(x, tuple): |
| 4094 | return tuple(_extract_meta(_x, nonempty) for _x in x) |
| 4095 | elif isinstance(x, dict): |
| 4096 | res = {} |
| 4097 | for k in x: |
| 4098 | res[k] = _extract_meta(x[k], nonempty) |
| 4099 | return res |
| 4100 | elif hasattr(x, "expr"): |
| 4101 | return _extract_meta(x.expr, nonempty) |
| 4102 | else: |
| 4103 | return x |
| 4104 | |
| 4105 | |
| 4106 | def emulate(func, *args, udf=False, **kwargs): |
no outgoing calls
no test coverage detected