Parquex.
View Source
A bounded columnar batch produced by a Parquex.Stream.
Columns are stored independently by name. to_rows/1 is explicit and can
materialize only this batch, never the complete stream.
Summary
Functions
Returns one column's bounded list of values.
Returns column names in schema order.
Builds one bounded batch from complete schema-named column lists.
Returns the number of rows in this bounded batch.
Returns the projected schema shared by the stream.
Explicitly expands this batch, and only this batch, to row maps.
Types
Functions
@spec column(t(), String.t()) :: {:ok, list()} | {:error, Parquex.Error.t()}
Returns one column's bounded list of values.
Returns column names in schema order.
@spec new(Parquex.Schema.t(), %{required(String.t()) => list()} | keyword()) :: {:ok, t()} | {:error, Parquex.Error.t()}
Builds one bounded batch from complete schema-named column lists.
@spec row_count(t()) :: non_neg_integer()
Returns the number of rows in this bounded batch.
@spec schema(t()) :: Parquex.Schema.t()
Returns the projected schema shared by the stream.
Explicitly expands this batch, and only this batch, to row maps.