Skip to content

Commit

Permalink
use future ordinal encoding feature
Browse files Browse the repository at this point in the history
  • Loading branch information
maartenbreddels committed Oct 11, 2021
1 parent 51a534f commit 1fe648e
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion packages/vaex-core/vaex/dataframe_protocol.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)))

0 comments on commit 1fe648e

Please sign in to comment.