class RecordBatchStreamWriter

RecordBatchStreamWriter(handle: ctypes.c_void_p, lib: ctypes.CDLL, is_buffer: bool = False)

Source: packages/irx/src/irx/record_batch.py:2040

RecordBatchStreamWriter.

Attributes

• _handle — Type: ctypes.c_void_p

• _lib — Type: ctypes.CDLL

• _is_buffer — Type: bool

• _closed — Type: bool

• _released — Type: bool

Methods

• __del__ — Release the writer when the object is garbage collected.

• __enter__ — Support using the writer as a context manager.

• __exit__ — Finalize successful contexts and abandon exceptional writes.

• __init__ — Wrap an existing native stream writer handle.

• buffer_data — buffer_data.

• close — Close the underlying stream writer.

• open_buffer — Open a stream writer backed by an in-memory buffer.

• open_csv — Create or truncate a local CSV file with an exact batch schema.

• open_file — Open a stream writer backed by a file path.

• open_parquet — Create Parquet output with buffered row groups and exact types.

• release — Release the underlying stream writer handle.

• write_batch — Write a completed batch to the stream.

Attributes

• _closed —

• _handle —

• _is_buffer —

• _lib —

• _released —