arrow

package

Go to main page

Versions in this module

v0

v0.0.8

May 24, 2026

v0.0.7

May 22, 2026

v0.0.6

May 22, 2026

Changes in this version

type Engine

+ func (e *Engine) NewDateColumn(name string, data []int64) dataset.AnyColumn

+ func (e *Engine) NewTimeColumn(name string, data []int64) dataset.AnyColumn

v0.0.5

May 21, 2026

Changes in this version

+ var ErrOutOfRange = errors.New("arrow: value out of range")

type Engine

+ func (e *Engine) Boxplot(yCol, groupCol dataset.AnyColumn, whisker string, notch bool) (dataset.Table, error)

+ func (e *Engine) First(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Histogram(col dataset.AnyColumn, nBins int) (dataset.Table, error)

+ func (e *Engine) KDE(ctx context.Context, col dataset.AnyColumn, bandwidth float64, points int) (dataset.Table, error)

+ func (e *Engine) Last(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) LinearFit(xCol, yCol dataset.AnyColumn, nOut int) (dataset.Table, error)

+ func (e *Engine) LinearFitSE(xCol, yCol dataset.AnyColumn, nOut int) (dataset.Table, error)

+ func (e *Engine) LoessFit(ctx context.Context, xCol, yCol dataset.AnyColumn, nOut int) (dataset.Table, error)

+ func (e *Engine) LoessFitSE(ctx context.Context, xCol, yCol dataset.AnyColumn, nOut int) (dataset.Table, error)

+ func (e *Engine) Mode(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Percentile(col dataset.AnyColumn, p float64) (dataset.AnyColumn, error)

+ func (e *Engine) StdDev(col dataset.AnyColumn) (dataset.AnyColumn, error)

v0.0.4

May 14, 2026

v0.0.2

May 11, 2026

Changes in this version

+ var ErrComputeTypeMismatch = errors.New("arrow: unexpected result type from compute kernel")

+ var ErrEmptyColumn = errors.New("arrow: empty column")

+ var ErrJoinKeyMismatch = errors.New("arrow: join key type mismatch")

+ var ErrLengthMismatch = errors.New("arrow: column length mismatch")

+ var ErrRequiresFloat64 = errors.New("arrow: operation requires float64 column")

+ var ErrRequiresInt64 = errors.New("arrow: operation requires int64 column")

+ var ErrRequiresNumeric = errors.New("arrow: operation requires numeric column")

+ var ErrTakeTypeMismatch = errors.New("arrow: unexpected result type from Take/Slice")

+ var ErrUnsupportedType = errors.New("arrow: unsupported column type")

v0.0.1

Apr 30, 2026

Changes in this version

+ type Engine struct

+ func NewEngine(ctx context.Context, alloc memory.Allocator) *Engine

+ func (e *Engine) Abs(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Acos(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) AddCols(a, b dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) AddScalar(col dataset.AnyColumn, val float64) (dataset.AnyColumn, error)

+ func (e *Engine) Alloc() memory.Allocator

+ func (e *Engine) Asin(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Atan(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Atan2(y, x dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) BitAnd(a, b dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) BitNot(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) BitOr(a, b dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) BitShiftLeft(col dataset.AnyColumn, n int) (dataset.AnyColumn, error)

+ func (e *Engine) BitShiftRight(col dataset.AnyColumn, n int) (dataset.AnyColumn, error)

+ func (e *Engine) BitXor(a, b dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Cast(col dataset.AnyColumn, target dataset.DType) (dataset.AnyColumn, error)

+ func (e *Engine) Ceil(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Combine(datasets ...dataset.Table) (dataset.Table, error)

+ func (e *Engine) Complete(ds dataset.Table, cols ...string) (dataset.Table, error)

+ func (e *Engine) Concatenate(ds dataset.Table, col string, from []string, sep string) (dataset.Table, error)

+ func (e *Engine) Context() context.Context

+ func (e *Engine) Cos(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Count(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) CumMax(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) CumMin(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) CumSum(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) DenseRank(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) DivCols(a, b dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) DropNA(ds dataset.Table, cols ...string) (dataset.Table, error)

+ func (e *Engine) Erf(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Exp(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Fill(col dataset.AnyColumn, dir dataset.FillDirection) (dataset.AnyColumn, error)

+ func (e *Engine) Filter(ds dataset.Table, mask dataset.Masker) (dataset.Table, error)

+ func (e *Engine) FilterIndices(mask []bool) []int

+ func (e *Engine) Floor(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) FromColumns(schema *dataset.Schema, cols ...dataset.AnyColumn) (dataset.Table, error)

+ func (e *Engine) Join(left, right dataset.Table, spec dataset.JoinSpec) (dataset.Table, error)

+ func (e *Engine) Lag(col dataset.AnyColumn, offset int) (dataset.AnyColumn, error)

+ func (e *Engine) Lead(col dataset.AnyColumn, offset int) (dataset.AnyColumn, error)

+ func (e *Engine) Ln(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Log10(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Log2(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Mean(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Median(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) MinMax(col dataset.AnyColumn) (dataset.AnyColumn, dataset.AnyColumn, error)

+ func (e *Engine) MulCols(a, b dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) MulScalar(col dataset.AnyColumn, val float64) (dataset.AnyColumn, error)

+ func (e *Engine) Name() string

+ func (e *Engine) Neg(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) NewBoolColumn(name string, data []bool) dataset.AnyColumn

+ func (e *Engine) NewBuilder(schema *dataset.Schema) dataset.Builder

+ func (e *Engine) NewFloat64Column(name string, data []float64) dataset.AnyColumn

+ func (e *Engine) NewInt64Column(name string, data []int64) dataset.AnyColumn

+ func (e *Engine) NewStringColumn(name string, data []string) dataset.AnyColumn

+ func (e *Engine) NewTimestampColumn(name string, data []int64) dataset.AnyColumn

+ func (e *Engine) PercentRank(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) PivotLonger(ds dataset.Table, spec dataset.PivotLongerSpec) (dataset.Table, error)

+ func (e *Engine) PivotWider(ds dataset.Table, spec dataset.PivotWiderSpec) (dataset.Table, error)

+ func (e *Engine) Pow(col dataset.AnyColumn, exp float64) (dataset.AnyColumn, error)

+ func (e *Engine) Rank(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) ReadCSV(ctx context.Context, r io.Reader, cfg dataset.CSVConfig) (dataset.Table, error)

+ func (e *Engine) ReadParquet(ctx context.Context, r io.ReaderAt, size int64, cfg dataset.ParquetConfig) (dataset.Table, error)

+ func (e *Engine) ReplaceNA(col dataset.AnyColumn, defaultVal float64) (dataset.AnyColumn, error)

+ func (e *Engine) Round(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) RowNumber(n int) (dataset.AnyColumn, error)

+ func (e *Engine) Select(col dataset.AnyColumn, indices []int) (dataset.AnyColumn, error)

+ func (e *Engine) Separate(ds dataset.Table, col string, into []string, sep string) (dataset.Table, error)

+ func (e *Engine) Sigmoid(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Sign(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Sin(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Slice(col dataset.AnyColumn, start, end int) (dataset.AnyColumn, error)

+ func (e *Engine) SortIndices(col dataset.AnyColumn) ([]int, error)

+ func (e *Engine) Sqrt(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Stack(datasets ...dataset.Table) (dataset.Table, error)

+ func (e *Engine) SubCols(a, b dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Sum(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Tan(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Tanh(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) Variance(col dataset.AnyColumn) (dataset.AnyColumn, error)

+ func (e *Engine) WriteCSV(ctx context.Context, w io.Writer, ds dataset.Table, cfg dataset.CSVConfig) error

+ func (e *Engine) WriteParquet(ctx context.Context, w io.Writer, ds dataset.Table, cfg dataset.ParquetConfig) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL