Skip to contents

Shared Delta Sharing reader

Shared Delta Sharing reader

Details

Internal base class for snapshot and change readers. Public readers inherit its Arrow and data-frame materializers.

Methods


Method to_arrow()

Materialize as an Arrow table.

Usage

SharingReader$to_arrow(batch_size = 65536L)

Arguments

batch_size

Rows per batch.

Returns

An arrow::Table.


Method to_arrow_reader()

Expose a lazy Arrow record batch reader. Consume it or call Close() when reading it directly. Once passed to a scanner such as DuckDB, let Arrow manage its lifetime rather than closing the underlying stream while it may still be in use.

Usage

SharingReader$to_arrow_reader(batch_size = 65536L)

Arguments

batch_size

Rows per batch.


Method to_tibble()

Materialize as a tibble using Arrow's R type conversion. BIGINT columns become bit64::integer64, including small values, empty results, and nested columns. A valid BIGINT value of -9223372036854775808 raises a conversion error because bit64 reserves that value for NA; use to_arrow() or to_arrow_reader() to retain it. Decimal columns use Arrow's default double conversion.

Usage

SharingReader$to_tibble(batch_size = 65536L)

Arguments

batch_size

Rows per batch.

Returns

A tibble::tbl_df.


Method to_data_frame()

Materialize as a base data frame by dropping the tibble class from to_tibble().

Usage

SharingReader$to_data_frame(batch_size = 65536L)

Arguments

batch_size

Rows per batch.

Returns

A data frame.


Method to_arrow_stream()

Materialize as a lazy Arrow C stream.

Usage

SharingReader$to_arrow_stream(batch_size = 65536L)

Arguments

batch_size

Rows per batch (1..1,000,000; default 65,536).

Returns

A nanoarrow_array_stream.


Method print()

Print the reader.

Usage

SharingReader$print(...)

Arguments

...

Ignored.