Core utilities that add pandas-esque features to arrow arrays and table.

Arrow forbids subclassing, so the classes are for logical grouping. Their methods are called as functions.

Column

class graphique.core.Column

Bases: pyarrow.lib.ChunkedArray

Chunked array interface as a namespace of functions.

absolute() → pyarrow.lib.ChunkedArray

Return absolute values.

call(func: Callable, *args) → pyarrow.lib.ChunkedArray

Call compute function on array with support for dictionaries.

count(value) → int

Return number of occurrences of value.

equal(value) → pyarrow.lib.ChunkedArray

Return boolean mask array which matches scalar value.

find(*values) → Iterator[slice]

Generate slices of matching rows from a sorted array.

is_in(values) → pyarrow.lib.ChunkedArray

Return boolean mask array which matches any value.

mask(func='and', **query) → pyarrow.lib.ChunkedArray

Return boolean mask array which matches query predicates.

max()

Return max of the values.

maximum(value) → pyarrow.lib.ChunkedArray

Return element-wise maximum of values.

mean() → Optional[float]

Return mean of the values.

min()

Return min of the values.

minimum(value) → pyarrow.lib.ChunkedArray

Return element-wise minimum of values.

mode()

Return mode of the values.

not_equal(value) → pyarrow.lib.ChunkedArray

Return boolean mask array which doesn’t match scalar value.

quantile(*q) → list

Return q-th quantiles for values.

range(lower=None, upper=None, include_lower=True, include_upper=False) → slice

Return slice within range from a sorted array, by default a half-open interval.

sort(reverse=False, length: int = None) → pyarrow.lib.Array

Return sorted values, optimized for fixed length.

stddev() → Optional[float]

Return standard deviation of the values.

sum(exp: int = 1)

Return sum of the values, with optional exponentiation.

variance() → Optional[float]

Return variance of the values.

Table

class graphique.core.Table

Bases: pyarrow.lib.Table

Table interface as a namespace of functions.

apply(name: str, alias: str = '', **partials) → pyarrow.lib.Table

Return view of table with functions applied across columns.

group(name: str, reverse=False, predicate=<class 'int'>, sort=False) → Iterator[pyarrow.lib.Table]

Generate tables grouped by column, with filtering and slicing on table length.

index() → list

Return index column names from pandas metadata.

is_in(name: str, *values) → pyarrow.lib.Table

Return rows which matches one of the values.

Assumes the table is sorted by the column name, i.e., indexed.

mask(name: str, **query) → pyarrow.lib.Array

Return mask array which matches query.

not_equal(name: str, value) → pyarrow.lib.Table

Return rows which don’t match the value.

Assumes the table is sorted by the column name, i.e., indexed.

range(name: str, lower=None, upper=None, **includes) → pyarrow.lib.Table

Return rows within range, by default a half-open interval.

Assumes the table is sorted by the column name, i.e., indexed.

sort(*names, reverse=False, length: int = None) → pyarrow.lib.Table

Return table sorted by columns.

types() → dict

Return mapping of column types.

unique(name: str, reverse=False, count='') → pyarrow.lib.Table

Return table with first or last occurrences from grouping by column.

Optionally include counts in an additional column. Faster than group() when only scalars are needed.