gobi

package module

Go to main page

Versions in this module

v0

v0.2.22

Jul 30, 2026

v0.2.21

Jul 30, 2026

v0.2.20

Jul 30, 2026

v0.2.19

Jul 30, 2026

Changes in this version

type Series

+ func SeriesFromArray(field arrow.Field, arr arrow.Array) Series

v0.2.18

Jul 30, 2026

v0.2.17

Jul 30, 2026

v0.2.16

Jul 30, 2026

Changes in this version

+ type PointExpr struct

+ Lat Expr

+ Lon Expr

v0.2.15

Jul 28, 2026

v0.2.14

Jul 28, 2026

v0.2.13

Jul 27, 2026

v0.2.12

Jul 27, 2026

v0.2.11

Jul 27, 2026

v0.2.10

Jul 27, 2026

Changes in this version

type Expr

+ func HaversineExpr(lat1, lon1, lat2, lon2 Expr, u geometry.Unit) Expr

+ func (e Expr) BitAnd(o Expr) Expr

+ func (e Expr) BitOr(o Expr) Expr

+ func (e Expr) BitXor(o Expr) Expr

+ func (e Expr) UnixNano() Expr

v0.2.9

Jul 26, 2026

Changes in this version

type AggKind

+ const AggMedian

+ const AggMode

type Expr

+ func (e Expr) Cast(target arrow.DataType) Expr

+ func (e Expr) Median() Expr

+ func (e Expr) Mode() Expr

type Series

+ func (s Series) Float32Values() ([]float32, bool)

+ func (s Series) Float64Values() ([]float64, bool)

+ func (s Series) HasNulls() bool

+ func (s Series) Int32Values() ([]int32, bool)

+ func (s Series) Int64Values() ([]int64, bool)

+ func (s Series) NullCount() int

+ func (s Series) Uint32Values() ([]uint32, bool)

+ func (s Series) Uint64Values() ([]uint64, bool)

v0.2.8

Jul 26, 2026

v0.2.7

Jul 26, 2026

Changes in this version

+ type IncrementalAggregator interface

+ Clone func() IncrementalAggregator

+ Finalize func() any

+ Update func(col Series, rows []int) error

v0.2.6

Jul 25, 2026

v0.2.5

Jul 25, 2026

Changes in this version

type Expr

+ func Coalesce(exprs ...Expr) Expr

+ func LitEmptyList(elemType arrow.DataType) Expr

v0.2.4

Jul 25, 2026

Changes in this version

type Aggregation

+ Filter Expr

type Aggregator

+ func NewInt32SetAggregator() Aggregator

+ func NewInt64SetAggregator() Aggregator

+ func NewStringSetAggregator() Aggregator

+ func NewUint32SetAggregator() Aggregator

+ func NewUint64SetAggregator() Aggregator

type Expr

+ func If(cond, a, b Expr) Expr

+ func LitNull(dtype arrow.DataType) Expr

+ func (e Expr) ListUnion(other Expr) Expr

type Frame

+ func (f *Frame) Rename(old, new string) (*Frame, error)

+ func (f *Frame) SelectCols(names ...string) (*Frame, error)

type LazyFrame

+ func (lf *LazyFrame) Rename(old, new string) *LazyFrame

+ func (lf *LazyFrame) SelectCols(names ...string) *LazyFrame

type Series

+ func (s Series) Bools() ([]bool, error)

+ func (s Series) Float32s() ([]float32, error)

+ func (s Series) Float64s() ([]float64, error)

+ func (s Series) Int32s() ([]int32, error)

+ func (s Series) Int64s() ([]int64, error)

+ func (s Series) Nulls() []bool

+ func (s Series) Strings() ([]string, error)

+ func (s Series) Timestamps() ([]arrow.Timestamp, error)

+ func (s Series) Uint32s() ([]uint32, error)

+ func (s Series) Uint64s() ([]uint64, error)

v0.2.3

Jul 25, 2026

Changes in this version

type Expr

+ func (e Expr) IsNotNull() Expr

+ func (e Expr) IsNull() Expr

v0.2.2

Jul 25, 2026

Changes in this version

type Expr

+ func (e Expr) OverOrdered(partitionCols []string, orderBy ...SortKey) Expr

v0.2.1

Jul 25, 2026

Changes in this version

type Expr

+ func (e Expr) Shift(n int) Expr

type LazyFrame

+ func (lf *LazyFrame) Explode(col string) *LazyFrame

v0.2.0

Jul 24, 2026

Changes in this version

+ func Aligned(meta *PartitionMetadata, columns []string) bool

+ func AlignedWith(l, r *PartitionMetadata) bool

type Aggregator

+ Merge func(other Aggregator) error

type Expr

+ func (e Expr) Count() Expr

+ func (e Expr) ListContains(elem any) Expr

+ func (e Expr) ListFirst() Expr

+ func (e Expr) ListGet(i int) Expr

+ func (e Expr) ListLast() Expr

+ func (e Expr) ListLen() Expr

+ func (e Expr) ListMax() Expr

+ func (e Expr) ListMean() Expr

+ func (e Expr) ListMin() Expr

+ func (e Expr) ListSlice(start, stop int) Expr

+ func (e Expr) ListSum() Expr

+ func (e Expr) MaxAgg() Expr

+ func (e Expr) Mean() Expr

+ func (e Expr) MinAgg() Expr

+ func (e Expr) Over(partitionCols ...string) Expr

+ func (e Expr) Sum() Expr

type Frame

+ func (f *Frame) PartitionMetadata() *PartitionMetadata

+ func (f *Frame) WithPartitionMeta(meta *PartitionMetadata) *Frame

type LazyFrame

+ func (lf *LazyFrame) PartitionMetadata() *PartitionMetadata

+ func (lf *LazyFrame) WithPartitionAssertion(assertion *PartitionMetadata) (*LazyFrame, error)

type LogicalPlan

+ PartitionMetadata func() *PartitionMetadata

+ type PartitionMetadata struct

+ Columns []string

+ HashFn string

+ SortEnforced bool

+ SortedBy []SortKey

+ func (m *PartitionMetadata) Clone() *PartitionMetadata

type ScanOption

+ func WithPartitionMetadata(meta *PartitionMetadata) ScanOption

v0.1.1

Jul 23, 2026

Changes in this version

+ var ErrUnsupportedStructField = errors.New("gobi: unsupported struct field type")

+ func ToStructs[T any](f *Frame) ([]T, error)

type Frame

+ func FromStructs[T any](rows []T) (*Frame, error)

v0.1.0

Jul 22, 2026

Changes in this version

+ const GeoParquetMetadataKey

+ const GeoParquetVersion

+ const MetaGeometryCRS

+ const MetaGeometryType

+ const SJoinMinParallelRows

+ var ErrColumnLenMismatch = errors.New("gobi: column length mismatch")

+ var ErrColumnNotFound = errors.New("gobi: column not found")

+ var ErrColumnTypeMismatch = errors.New("gobi: column type mismatch")

+ var ErrEmptyFrame = errors.New("gobi: empty dataframe")

+ var ErrExprTypeMismatch = errors.New("gobi: expression type mismatch")

+ var ErrMaskNotBoolean = fmt.Errorf("gobi: filter mask must be a boolean series")

+ var ErrNotDateTime = fmt.Errorf("gobi: series is not a datetime column")

+ var ErrNotGeometry = errors.New("gobi: column is not a geometry column")

+ var ErrNotMonotonic = fmt.Errorf("gobi: time column must be monotonically non-decreasing")

+ var ErrNotNumeric = fmt.Errorf("gobi: series is not numeric")

+ var ErrRowOutOfRange = errors.New("gobi: row index out of range")

+ var ErrUnsupportedLiteral = errors.New("gobi: unsupported literal type")

+ func CanPossiblyMatch(pred Expr, stats Stats) bool

+ func ExprToSQL(e Expr) (string, []any, bool)

+ func GeoParquetSchemaWithMetadata(schema *arrow.Schema, meta *GeoParquetMetadata) (*arrow.Schema, error)

+ func GeometryField(name string, epsg int32) arrow.Field

+ func MarshalGeoParquetMetadata(meta *GeoParquetMetadata) (string, error)

+ func MaxParallelism() int

+ func SetMaxParallelism(n int)

+ type AggKind uint8

+ const AggCount

+ const AggFirst

+ const AggLast

+ const AggMax

+ const AggMean

+ const AggMin

+ const AggNUnique

+ const AggStd

+ const AggSum

+ const AggVar

+ func (k AggKind) String() string

+ type Aggregation struct

+ Alias string

+ Column string

+ Fn Aggregator

+ Kind AggKind

+ type Aggregator interface

+ Aggregate func(s Series, rows []int) (any, error)

+ Name func() string

+ Type func() arrow.DataType

+ type CalendarUnit uint8

+ const CalendarMonth

+ const CalendarWeek

+ const CalendarYear

+ type ExecOperator interface

+ Close func() error

+ Next func(ctx context.Context) (arrow.RecordBatch, error)

+ Schema func() *arrow.Schema

+ func Compile(p LogicalPlan) (ExecOperator, error)

+ type Expr struct

+ func Col(name string) Expr

+ func Custom(node ExprNode) Expr

+ func Lit(v any) Expr

+ func SplitConjuncts(e Expr) []Expr

+ func (e Expr) Add(o Expr) Expr

+ func (e Expr) Alias(name string) Expr

+ func (e Expr) And(o Expr) Expr

+ func (e Expr) Div(o Expr) Expr

+ func (e Expr) Eq(o Expr) Expr

+ func (e Expr) Ge(o Expr) Expr

+ func (e Expr) Gt(o Expr) Expr

+ func (e Expr) Le(o Expr) Expr

+ func (e Expr) Lt(o Expr) Expr

+ func (e Expr) Mul(o Expr) Expr

+ func (e Expr) Ne(o Expr) Expr

+ func (e Expr) Node() ExprNode

+ func (e Expr) Not() Expr

+ func (e Expr) Or(o Expr) Expr

+ func (e Expr) String() string

+ func (e Expr) Sub(o Expr) Expr

+ type ExprNode interface

+ Children func() []Expr

+ Eval func(input *Frame) (Series, error)

+ String func() string

+ Type func(schema *arrow.Schema) (arrow.DataType, error)

+ type Frame struct

+ func Concat(frames ...*Frame) (*Frame, error)

+ func Execute(ctx context.Context, op ExecOperator) (*Frame, error)

+ func NewFrame(schema *arrow.Schema, cols []arrow.Column) (*Frame, error)

+ func NewFrameFromTable(t arrow.Table) *Frame

+ func (f *Frame) Column(name string) (Series, error)

+ func (f *Frame) ColumnAt(i int) (Series, error)

+ func (f *Frame) ColumnNames() []string

+ func (f *Frame) Concat(others ...*Frame) (*Frame, error)

+ func (f *Frame) Difference(other *Frame, cols ...string) (*Frame, error)

+ func (f *Frame) DropColumn(name string) (*Frame, error)

+ func (f *Frame) Explode(geomCol string) (*Frame, error)

+ func (f *Frame) Filter(mask Series) (*Frame, error)

+ func (f *Frame) FilterExpr(e Expr) (*Frame, error)

+ func (f *Frame) Geometry(colName string, row int) (any, error)

+ func (f *Frame) GroupBy(keys ...string) (*GroupBy, error)

+ func (f *Frame) Head(n int) *Frame

+ func (f *Frame) Intersect(other *Frame, cols ...string) (*Frame, error)

+ func (f *Frame) Join(right *Frame, leftKey, rightKey string, kind JoinType) (*Frame, error)

+ func (f *Frame) Lazy() *LazyFrame

+ func (f *Frame) NumCols() int

+ func (f *Frame) NumRows() int

+ func (f *Frame) Pivot(index, columns, values string, agg AggKind) (*Frame, error)

+ func (f *Frame) Release()

+ func (f *Frame) ResampleEvery(timeCol string, interval time.Duration) (*Resampler, error)

+ func (f *Frame) Retain()

+ func (f *Frame) RollingBy(timeCol string, period time.Duration) (*TimeRolling, error)

+ func (f *Frame) Row(i int) (*Frame, error)

+ func (f *Frame) SJoin(right *Frame, leftGeomCol, rightGeomCol string, pred SpatialPredicate, ...) (*Frame, error)

+ func (f *Frame) Schema() *arrow.Schema

+ func (f *Frame) Shape() (rows, cols int)

+ func (f *Frame) SortBy(keys ...SortKey) (*Frame, error)

+ func (f *Frame) String() string

+ func (f *Frame) Table() arrow.Table

+ func (f *Frame) Tail(n int) *Frame

+ func (f *Frame) Take(indexes []int) (*Frame, error)

+ func (f *Frame) Union(other *Frame, cols ...string) (*Frame, error)

+ func (f *Frame) Unique(cols ...string) (*Frame, error)

+ func (f *Frame) ValueCounts(col string) (*Frame, error)

+ func (f *Frame) WithColumn(name string, s Series) (*Frame, error)

+ func (f *Frame) WithColumnExpr(name string, e Expr) (*Frame, error)

+ type GeoParquetColumnMeta struct

+ Bbox []float64

+ CRS map[string]any

+ Encoding string

+ GeometryTypes []string

+ type GeoParquetMetadata struct

+ Columns map[string]GeoParquetColumnMeta

+ PrimaryColumn string

+ Version string

+ func BuildGeoParquetMetadata(f *Frame) (*GeoParquetMetadata, error)

+ func ParseGeoParquetMetadata(raw string) (*GeoParquetMetadata, error)

+ type GroupBy struct

+ func (g *GroupBy) Agg(aggs ...Aggregation) (*Frame, error)

+ type JoinType uint8

+ const JoinAnti

+ const JoinFull

+ const JoinInner

+ const JoinLeft

+ const JoinRight

+ const JoinSemi

+ type LazyFrame struct

+ func NewLazyFrame(plan LogicalPlan) *LazyFrame

+ func (lf *LazyFrame) Collect() (*Frame, error)

+ func (lf *LazyFrame) CollectRaw() (*Frame, error)

+ func (lf *LazyFrame) DropColumn(name string) *LazyFrame

+ func (lf *LazyFrame) Explain() string

+ func (lf *LazyFrame) ExplainOptimized() string

+ func (lf *LazyFrame) ExplainPhysical() string

+ func (lf *LazyFrame) Filter(cond Expr) *LazyFrame

+ func (lf *LazyFrame) GroupBy(keys ...string) *LazyGroupBy

+ func (lf *LazyFrame) Head(n int) *LazyFrame

+ func (lf *LazyFrame) Join(right *LazyFrame, leftKey, rightKey string, kind JoinType) *LazyFrame

+ func (lf *LazyFrame) Limit(n int) *LazyFrame

+ func (lf *LazyFrame) Optimize() LogicalPlan

+ func (lf *LazyFrame) Plan() LogicalPlan

+ func (lf *LazyFrame) Schema() *arrow.Schema

+ func (lf *LazyFrame) Select(exprs ...Expr) *LazyFrame

+ func (lf *LazyFrame) SortBy(keys ...SortKey) *LazyFrame

+ func (lf *LazyFrame) Tail(n int) *LazyFrame

+ func (lf *LazyFrame) WithColumn(name string, e Expr) *LazyFrame

+ type LazyGroupBy struct

+ func (lg *LazyGroupBy) Agg(aggs ...Aggregation) *LazyFrame

+ type LogicalPlan interface

+ Children func() []LogicalPlan

+ Schema func() *arrow.Schema

+ String func() string

+ func NewScanNode(label string, schema *arrow.Schema, read func() (*Frame, error), ...) LogicalPlan

+ func Optimize(plan LogicalPlan, rules ...Rule) LogicalPlan

+ type Namer interface

+ OutputName func() string

+ type Option interface

+ func Workers(n int) Option

+ type PredicateSink interface

+ ApplyPredicate func(pred Expr) LogicalPlan

+ type ProjectableScan interface

+ ProjectColumns func(cols []string) LogicalPlan

+ type Resampler struct

+ func (r *Resampler) Agg(aggs ...Aggregation) (*Frame, error)

+ type Rule interface

+ Apply func(plan LogicalPlan) (rewritten LogicalPlan, changed bool)

+ Name func() string

+ func DefaultRules() []Rule

+ type ScanOption func(*scanFileNode)

+ func WithColumnProjection(fn func(cols []string) LogicalPlan) ScanOption

+ func WithParallelStreamReads(fn func() []func(cb func(*Frame) error) error) ScanOption

+ func WithPredicatePushdown(fn func(pred Expr) LogicalPlan) ScanOption

+ func WithStreamRead(fn func(cb func(*Frame) error) error) ScanOption

+ type Series struct

+ func NewSeries(col *arrow.Column) Series

+ func NewTimestampSeries(name string, ts []time.Time, validity []bool) Series

+ func PointsFromXY(x, y Series, crs int32) (Series, error)

+ func PointsFromXYZ(x, y, z Series, crs int32) (Series, error)

+ func (s Series) Add(o Series) (Series, error)

+ func (s Series) AddDuration(d time.Duration) (Series, error)

+ func (s Series) AddScalar(v float64) (Series, error)

+ func (s Series) Column() *arrow.Column

+ func (s Series) Concat(others ...Series) (Series, error)

+ func (s Series) Count() int

+ func (s Series) DataType() arrow.DataType

+ func (s Series) Day() (Series, error)

+ func (s Series) DayOfYear() (Series, error)

+ func (s Series) Diff(n int) (Series, error)

+ func (s Series) DiffDuration(other Series) (Series, error)

+ func (s Series) Difference(other Series) (Series, error)

+ func (s Series) Div(o Series) (Series, error)

+ func (s Series) DivScalar(v float64) (Series, error)

+ func (s Series) Eq(o Series) (Series, error)

+ func (s Series) EqScalar(v float64) (Series, error)

+ func (s Series) EqTime(t time.Time) (Series, error)

+ func (s Series) Ge(o Series) (Series, error)

+ func (s Series) GeTime(t time.Time) (Series, error)

+ func (s Series) GeomArea(u geometry.Unit) (Series, error)

+ func (s Series) GeomBounds() (*Frame, error)

+ func (s Series) GeomCentroid() (Series, error)

+ func (s Series) GeomLength(u geometry.Unit) (Series, error)

+ func (s Series) Geometry(i int) (geometry.Geometry, error)

+ func (s Series) Gt(o Series) (Series, error)

+ func (s Series) GtScalar(v float64) (Series, error)

+ func (s Series) GtTime(t time.Time) (Series, error)

+ func (s Series) Head(n int) Series

+ func (s Series) Hour() (Series, error)

+ func (s Series) Intersect(other Series) (Series, error)

+ func (s Series) IsDateTime() bool

+ func (s Series) IsGeometry() bool

+ func (s Series) Le(o Series) (Series, error)

+ func (s Series) LeTime(t time.Time) (Series, error)

+ func (s Series) Len() int

+ func (s Series) Lt(o Series) (Series, error)

+ func (s Series) LtScalar(v float64) (Series, error)

+ func (s Series) LtTime(t time.Time) (Series, error)

+ func (s Series) Max() (float64, error)

+ func (s Series) Mean() (float64, error)

+ func (s Series) Min() (float64, error)

+ func (s Series) Minute() (Series, error)

+ func (s Series) Month() (Series, error)

+ func (s Series) Mul(o Series) (Series, error)

+ func (s Series) MulScalar(v float64) (Series, error)

+ func (s Series) NUnique() (int64, error)

+ func (s Series) Name() string

+ func (s Series) Ne(o Series) (Series, error)

+ func (s Series) NeTime(t time.Time) (Series, error)

+ func (s Series) RollingCount(window int) (Series, error)

+ func (s Series) RollingMax(window int) (Series, error)

+ func (s Series) RollingMean(window int) (Series, error)

+ func (s Series) RollingMin(window int) (Series, error)

+ func (s Series) RollingSum(window int) (Series, error)

+ func (s Series) Row(i int) (Series, error)

+ func (s Series) Second() (Series, error)

+ func (s Series) Shift(n int) (Series, error)

+ func (s Series) Sub(o Series) (Series, error)

+ func (s Series) SubDuration(d time.Duration) (Series, error)

+ func (s Series) SubScalar(v float64) (Series, error)

+ func (s Series) Sum() (float64, error)

+ func (s Series) Tail(n int) Series

+ func (s Series) TimeAt(i int) (time.Time, bool, error)

+ func (s Series) Timezone() string

+ func (s Series) TruncateTo(unit TimeUnit) (Series, error)

+ func (s Series) TruncateToCalendar(unit CalendarUnit) (Series, error)

+ func (s Series) Union(other Series) (Series, error)

+ func (s Series) Unique() (Series, error)

+ func (s Series) Weekday() (Series, error)

+ func (s Series) WithTimezone(tz string) (Series, error)

+ func (s Series) Year() (Series, error)

+ type SortKey struct

+ Column string

+ Descending bool

+ type SpatialPredicate uint8

+ const SPContains

+ const SPIntersects

+ const SPWithin

+ func (p SpatialPredicate) String() string

+ type Stats interface

+ MinMax func(col string) (minV, maxV any, ok bool)

+ NullCount func(col string) (n int64, ok bool)

+ TotalRows func() int64

+ type TimeRolling struct

+ func (r *TimeRolling) Agg(column string, kind AggKind) (Series, error)

+ type TimeUnit uint8

+ const UnitDay

+ const UnitHour

+ const UnitMicrosecond

+ const UnitMillisecond

+ const UnitMinute

+ const UnitNanosecond

+ const UnitSecond

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