Parquex.Stream (parquex v0.3.0)

A single-pass, pull-based stream of bounded Parquex.Batch values.

Each downstream demand calls the native reader once. Halting enumeration or a consumer exception runs the stream finalizer and closes native state.

Summary

t()

close(stream)

Closes and cancels the native reader. This operation is idempotent.

schema(stream)

Returns the projected schema without advancing the stream.

stats(stream)

Returns deterministic native buffering and range-read counters.

@opaque t()

@spec close(t()) :: :ok | {:error, Parquex.Error.t()}

Closes and cancels the native reader. This operation is idempotent.

@spec schema(t()) :: Parquex.Schema.t()

Returns the projected schema without advancing the stream.

@spec stats(t()) :: {:ok, map()} | {:error, Parquex.Error.t()}

Returns deterministic native buffering and range-read counters.