| 1747 | |
| 1748 | |
| 1749 | class ToFrame(Elemwise): |
| 1750 | _parameters = ["frame", "name"] |
| 1751 | _defaults = {"name": no_default} |
| 1752 | _keyword_only = ["name"] |
| 1753 | operation = M.to_frame |
| 1754 | _filter_passthrough = True |
| 1755 | |
| 1756 | @functools.cached_property |
| 1757 | def unique_partition_mapping_columns_from_shuffle(self): |
| 1758 | result = set() |
| 1759 | name_mapping = dict(zip(self.frame.columns, self.columns)) |
| 1760 | for elem in self.frame.unique_partition_mapping_columns_from_shuffle: |
| 1761 | if isinstance(elem, tuple): |
| 1762 | result.add(tuple(name_mapping.get(v, v) for v in elem)) |
| 1763 | else: |
| 1764 | result.add(name_mapping.get(elem, elem)) |
| 1765 | return result |
| 1766 | |
| 1767 | |
| 1768 | class ToFrameIndex(ToFrame): |
no outgoing calls
no test coverage detected