pyarrow.acero.RecordBatchReaderSourceNodeOptions

class pyarrow.acero.RecordBatchReaderSourceNodeOptions(reader)

Bases: _RecordBatchReaderSourceNodeOptions

A Source node which streams data from a RecordBatchReader.

This is the option class for the “record_batch_reader_source” node factory.

Parameters:

readerpyarrow.RecordBatchReader

The reader which acts as the data source.

__init__(self, RecordBatchReader reader)

Methods

__init__(self, RecordBatchReader reader)