(df: dd.DataFrame)
| 1248 | |
| 1249 | |
| 1250 | def _df_column_uniquify(df: dd.DataFrame) -> Tuple[dd.DataFrame, List[str]]: |
| 1251 | df_columns = df.columns |
| 1252 | new_columns = [] |
| 1253 | duplicate_cols = [] |
| 1254 | for item in df_columns: |
| 1255 | counter = 0 |
| 1256 | newitem = item |
| 1257 | while newitem in new_columns: |
| 1258 | counter += 1 |
| 1259 | newitem = "{}_{}".format(item, counter) |
| 1260 | if counter > 0: |
| 1261 | duplicate_cols.append(newitem) |
| 1262 | new_columns.append(newitem) |
| 1263 | df.columns = new_columns |
| 1264 | return df, duplicate_cols |
no outgoing calls
no test coverage detected