| 18 | |
| 19 | |
| 20 | class DaskDataFrameInterchange: |
| 21 | def __init__( |
| 22 | self, df: DataFrame, nan_as_null: bool = False, allow_copy: bool = True |
| 23 | ) -> None: |
| 24 | self._df = df |
| 25 | self._nan_as_null = nan_as_null |
| 26 | self._allow_copy = allow_copy |
| 27 | |
| 28 | def get_columns(self): |
| 29 | return [DaskColumn(self._df[name]) for name in self._df.columns] |
| 30 | |
| 31 | def column_names(self): |
| 32 | return self._df.columns |
| 33 | |
| 34 | def num_columns(self) -> int: |
| 35 | return len(self._df.columns) |
| 36 | |
| 37 | def num_rows(self) -> int: |
| 38 | return len(self._df) |
| 39 | |
| 40 | |
| 41 | class DaskColumn: |