(
table: dd.DataFrame,
field_mapping: Dict[str, str],
)
| 1004 | |
| 1005 | |
| 1006 | def _run_dask_field_mapping( |
| 1007 | table: dd.DataFrame, |
| 1008 | field_mapping: Dict[str, str], |
| 1009 | ): |
| 1010 | if field_mapping: |
| 1011 | # run field mapping in the forward direction |
| 1012 | table = table.rename(columns=field_mapping) |
| 1013 | table = table.persist() |
| 1014 | |
| 1015 | return table |
| 1016 | |
| 1017 | |
| 1018 | def _field_mapping( |
no test coverage detected