Skip to content

Commit

Permalink
ruff
Browse files Browse the repository at this point in the history
  • Loading branch information
robert3005 committed Oct 23, 2024
1 parent c3af36f commit c09e5a2
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pyvortex/python/vortex/dataset.py
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@ def take(
use_threads: bool | None = None,
memory_pool: pa.MemoryPool = None,
) -> pa.Table:
return self._dataset.to_array(columns, batch_size, filter).take(encoding.array(indices)).to_arrow_table()
return self._dataset.to_array(columns, filter).take(encoding.array(indices)).to_arrow_table()

def to_record_batch_reader(
self,
Expand Down Expand Up @@ -211,7 +211,7 @@ def to_table(
del memory_pool
if filter is not None:
filter = arrow_to_vortex_expr(filter, self.schema)
return self._dataset.to_array(columns, batch_size, filter).to_arrow_table()
return self._dataset.to_array(columns, filter).to_arrow_table()


class VortexScanner(pa.dataset.Scanner):
Expand Down

0 comments on commit c09e5a2

Please sign in to comment.