API reference
python:irx:irx.record_batch.RecordBatchStreamReader
class RecordBatchStreamReader
RecordBatchStreamReader(handle: ctypes.c_void_p, lib: ctypes.CDLL)
Source: packages/irx/src/irx/record_batch.py:2337
RecordBatchStreamReader.
Attributes
-
_handle — Type: ctypes.c_void_p
-
_lib — Type: ctypes.CDLL
-
_closed — Type: bool
Methods
-
__del__ — Release the reader when the object is garbage collected.
-
__enter__ — Support using the reader as a context manager.
-
__exit__ — Close and release the reader from a context manager.
-
__init__ — Wrap an existing native stream reader handle.
-
__iter__ — Iterate batches from the stream until exhaustion.
-
close — Close the underlying stream reader.
-
next_batch — Return the next RecordBatch or None at end-of-stream.
-
open_buffer — Open a stream reader backed by an in-memory buffer.
-
open_csv — Stream a local UTF-8 CSV file with explicit or first-block schema.
-
open_file — Open a stream reader backed by a file path.
-
open_parquet — Stream configured Parquet batches, optionally asserting the schema.
-
schema — Return an independent schema snapshot before or after EOF.