amol- commented on code in PR #13409:
URL: https://github.com/apache/arrow/pull/13409#discussion_r913876367
##########
python/pyarrow/_exec_plan.pyx:
##########
@@ -95,6 +98,23 @@ cdef execplan(inputs, output_type, vector[CDeclaration]
plan, c_bool use_threads
c_in_table, 1 << 20)
c_input_node_opts = static_pointer_cast[CExecNodeOptions,
CTableSourceNodeOptions](
c_tablesourceopts)
+ elif isinstance(ipt, FilteredDataset):
Review Comment:
@westonpace might have a better answer.
Going for CScanNode I would had to manually provide the `ScanOptions` myself.
I went for making a `RecordBatchReader` as that way I could reuse the Python
logic in `FilteredDataset` that creates a scanner with the right filter, also
in the future if `FilteredDataset._make_scanner` is extended to take care of
more options, this code would benefit from that support for free.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@arrow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
