From 1fe648e6b1ffe41d91d53a4991aeec32b8362d6e Mon Sep 17 00:00:00 2001 From: "Maarten A. Breddels" Date: Mon, 11 Oct 2021 15:07:29 +0200 Subject: [PATCH] use future ordinal encoding feature --- packages/vaex-core/vaex/dataframe_protocol.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/vaex-core/vaex/dataframe_protocol.py b/packages/vaex-core/vaex/dataframe_protocol.py index 223bd3cad9..7f6ce805a5 100644 --- a/packages/vaex-core/vaex/dataframe_protocol.py +++ b/packages/vaex-core/vaex/dataframe_protocol.py @@ -751,7 +751,7 @@ def get_chunks(self, n_chunks: Optional[int] = None) -> Iterable["_VaexDataFrame size = self.num_rows() chunk_size = (size + n_chunks - 1) // n_chunks column_names = self.column_names() - i = self._df.evaluate_iterator(column_names, chunk_size=chunk_size) + i = self._df._future().evaluate_iterator(column_names, chunk_size=chunk_size) for i1, i2, chunk in i: yield _VaexDataFrame(vaex.from_items(*zip(column_names, chunk)))