archery

package module

Go to main page

Versions in this module

v0

v0.4.0

Mar 17, 2025

Changes in this version

+ func Abs(ctx context.Context, a arrow.Array) (arrow.Array, error)

+ func AddColumnScalar(ctx context.Context, rec arrow.Record, colName string, val interface{}) (arrow.Record, error)

+ func AddColumns(ctx context.Context, a, b arrow.Record, colName string) (arrow.Record, error)

+ func All(ctx context.Context, input arrow.Array) (bool, error)

+ func And(ctx context.Context, a, b arrow.Array) (arrow.Array, error)

+ func Any(ctx context.Context, input arrow.Array) (bool, error)

+ func ColumnNames(rec arrow.Record) []string

+ func CountColumn(ctx context.Context, rec arrow.Record, colName string) (int64, error)

+ func CountNull(ctx context.Context, input arrow.Array) int64

+ func CountValues(ctx context.Context, input arrow.Array) (values arrow.Array, counts arrow.Array, err error)

+ func DivideColumnScalar(ctx context.Context, rec arrow.Record, colName string, val interface{}) (arrow.Record, error)

+ func DivideColumns(ctx context.Context, a, b arrow.Record, colName string) (arrow.Record, error)

+ func EqualScalar(ctx context.Context, input arrow.Array, val interface{}) (arrow.Array, error)

+ func Filter(ctx context.Context, input arrow.Array, mask arrow.Array) (arrow.Array, error)

+ func FilterRecord(ctx context.Context, input arrow.Record, mask arrow.Array) (arrow.Record, error)

+ func FilterRecordByColumnRange(ctx context.Context, input arrow.Record, colName string, min, max interface{}) (arrow.Record, error)

+ func FilterRecordByColumnValue(ctx context.Context, input arrow.Record, colName string, val interface{}) (arrow.Record, error)

+ func GetColumn(rec arrow.Record, name string) (arrow.Array, error)

+ func GetColumnIndex(rec arrow.Record, name string) (int, error)

+ func Greater(ctx context.Context, a, b arrow.Array) (arrow.Array, error)

+ func GreaterEqual(ctx context.Context, a, b arrow.Array) (arrow.Array, error)

+ func GreaterEqualScalar(ctx context.Context, input arrow.Array, val interface{}) (arrow.Array, error)

+ func GreaterScalar(ctx context.Context, input arrow.Array, val interface{}) (arrow.Array, error)

+ func Invert(ctx context.Context, input arrow.Array) (arrow.Array, error)

+ func IsNull(ctx context.Context, input arrow.Array) (arrow.Array, error)

+ func IsValid(ctx context.Context, input arrow.Array) (arrow.Array, error)

+ func Less(ctx context.Context, a, b arrow.Array) (arrow.Array, error)

+ func LessEqual(ctx context.Context, a, b arrow.Array) (arrow.Array, error)

+ func LessEqualScalar(ctx context.Context, input arrow.Array, val interface{}) (arrow.Array, error)

+ func LessScalar(ctx context.Context, input arrow.Array, val interface{}) (arrow.Array, error)

+ func MaxColumn(ctx context.Context, rec arrow.Record, colName string) (interface{}, error)

+ func MeanColumn(ctx context.Context, rec arrow.Record, colName string) (float64, error)

+ func MinColumn(ctx context.Context, rec arrow.Record, colName string) (interface{}, error)

+ func Mode(ctx context.Context, input arrow.Array) (interface{}, error)

+ func MultiplyColumnScalar(ctx context.Context, rec arrow.Record, colName string, val interface{}) (arrow.Record, error)

+ func MultiplyColumns(ctx context.Context, a, b arrow.Record, colName string) (arrow.Record, error)

+ func NotEqual(ctx context.Context, a, b arrow.Array) (arrow.Array, error)

+ func NotEqualScalar(ctx context.Context, input arrow.Array, val interface{}) (arrow.Array, error)

+ func Or(ctx context.Context, a, b arrow.Array) (arrow.Array, error)

+ func ReleaseArray(arr arrow.Array)

+ func ReleaseRecord(rec arrow.Record)

+ func ReplaceRecordColumn(rec arrow.Record, colIndex int, newCol arrow.Array) arrow.Record

+ func ReplaceRecordColumnByName(rec arrow.Record, colName string, newCol arrow.Array) (arrow.Record, error)

+ func SortIndices(ctx context.Context, input arrow.Array, order SortOrder) (arrow.Array, error)

+ func SortRecord(ctx context.Context, input arrow.Record, sortCols []string, ...) (arrow.Record, error)

+ func Sqrt(ctx context.Context, a arrow.Array) (arrow.Array, error)

+ func StandardDeviationColumn(ctx context.Context, rec arrow.Record, colName string) (float64, error)

+ func SubtractColumnScalar(ctx context.Context, rec arrow.Record, colName string, val interface{}) (arrow.Record, error)

+ func SubtractColumns(ctx context.Context, a, b arrow.Record, colName string) (arrow.Record, error)

+ func SumColumn(ctx context.Context, rec arrow.Record, colName string) (interface{}, error)

+ func VarianceColumn(ctx context.Context, rec arrow.Record, colName string) (float64, error)

+ func Xor(ctx context.Context, a, b arrow.Array) (arrow.Array, error)

v0.3.0

Mar 16, 2025

Changes in this version

+ func AggregateRecordColumn(ctx context.Context, record arrow.Record, columnName string, ...) (interface{}, error)

+ func FilterRecordBetween(ctx context.Context, record arrow.Record, columnName string, ...) (arrow.Record, error)

+ func FilterRecordByColumn(ctx context.Context, record arrow.Record, columnName string, ...) (arrow.Record, error)

+ func FilterRecordByMask(ctx context.Context, record arrow.Record, mask *array.Boolean, ...) (arrow.Record, error)

+ func FilterRecordEqual(ctx context.Context, record arrow.Record, columnName string, value interface{}, ...) (arrow.Record, error)

+ func FilterRecordGreaterThan(ctx context.Context, record arrow.Record, columnName string, value interface{}, ...) (arrow.Record, error)

+ func FilterRecordLessThan(ctx context.Context, record arrow.Record, columnName string, value interface{}, ...) (arrow.Record, error)

+ func FilterRecordRows(ctx context.Context, record arrow.Record, predicate func(int) bool, ...) (arrow.Record, error)

+ func GetRecordColumn(record arrow.Record, columnName string) (arrow.Array, error)

+ func MaxRecordColumn(ctx context.Context, record arrow.Record, columnName string, ...) (interface{}, error)

+ func MeanRecordColumn(ctx context.Context, record arrow.Record, columnName string, ...) (float64, error)

+ func MinRecordColumn(ctx context.Context, record arrow.Record, columnName string, ...) (interface{}, error)

+ func SortRecordByColumn(ctx context.Context, record arrow.Record, columnName string, order SortOrder, ...) (arrow.Record, error)

+ func SumRecordColumn(ctx context.Context, record arrow.Record, columnName string, ...) (interface{}, error)

type GroupByResult

+ func GroupByRecord(ctx context.Context, record arrow.Record, keyColumns []string, ...) (*GroupByResult, error)

v0.2.0

Mar 16, 2025

Changes in this version

+ func Between(lower, upper interface{}) func(arrow.Array, int) bool

+ func Equal(value interface{}) func(arrow.Array, int) bool

+ func GreaterThan(value interface{}) func(arrow.Array, int) bool

+ func LessThan(value interface{}) func(arrow.Array, int) bool

+ func MaxAggregator() func(context.Context, arrow.Array) (interface{}, error)

+ func MeanAggregator() func(context.Context, arrow.Array) (interface{}, error)

+ func MinAggregator() func(context.Context, arrow.Array) (interface{}, error)

+ func SumAggregator() func(context.Context, arrow.Array) (interface{}, error)

+ type GroupByResult struct

+ Aggregates map[string]arrow.Array

+ Keys map[string]arrow.Array

+ func (gr *GroupByResult) Release()

+ func (gr *GroupByResult) ToRecord(mem memory.Allocator) arrow.Record

+ type RecordWrapper struct

+ func NewRecordWrapper(record arrow.Record, mem memory.Allocator) *RecordWrapper

+ func (rw *RecordWrapper) AggregateColumn(ctx context.Context, columnName string, ...) (interface{}, error)

+ func (rw *RecordWrapper) Column(name string) (arrow.Array, error)

+ func (rw *RecordWrapper) ColumnByIndex(i int) (arrow.Array, error)

+ func (rw *RecordWrapper) ColumnNames() []string

+ func (rw *RecordWrapper) FilterByMask(ctx context.Context, mask *array.Boolean) (arrow.Record, error)

+ func (rw *RecordWrapper) FilterRows(ctx context.Context, predicate func(int) bool) (arrow.Record, error)

+ func (rw *RecordWrapper) FilterRowsByColumn(ctx context.Context, columnName string, condition func(arrow.Array, int) bool) (arrow.Record, error)

+ func (rw *RecordWrapper) GroupBy(ctx context.Context, keyColumns []string, ...) (*GroupByResult, error)

+ func (rw *RecordWrapper) Record() arrow.Record

+ func (rw *RecordWrapper) SortRecord(ctx context.Context, columnName string, order SortOrder) (arrow.Record, error)

v0.1.0

Mar 16, 2025

Changes in this version

+ func AbsoluteValue(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Acos(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Add(ctx context.Context, left, right arrow.Array) (arrow.Array, error)

+ func AddScalar(ctx context.Context, arr arrow.Array, val interface{}) (arrow.Array, error)

+ func Asin(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Atan(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Cos(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Count(ctx context.Context, arr arrow.Array) (int64, error)

+ func CountNonNull(ctx context.Context, arr arrow.Array) (int64, error)

+ func CreateBooleanArray(mem memory.Allocator, values []bool, validity []bool) *array.Boolean

+ func CreateBooleanMask(ctx context.Context, arr arrow.Array, fn func(int) bool) *array.Boolean

+ func CreateFloat64Array(mem memory.Allocator, values []float64, validity []bool) *array.Float64

+ func CreateInt64Array(mem memory.Allocator, values []int64, validity []bool) *array.Int64

+ func CreateStringArray(mem memory.Allocator, values []string, validity []bool) *array.String

+ func DatumToArray(datum compute.Datum) arrow.Array

+ func DatumToBooleanArray(datum compute.Datum) *array.Boolean

+ func DatumToFloat64Array(datum compute.Datum) *array.Float64

+ func DatumToInt64Array(datum compute.Datum) *array.Int64

+ func DatumToStringArray(datum compute.Datum) *array.String

+ func Divide(ctx context.Context, left, right arrow.Array) (arrow.Array, error)

+ func DivideScalar(ctx context.Context, arr arrow.Array, val interface{}) (arrow.Array, error)

+ func ExtractBooleanValues(arr *array.Boolean) []*bool

+ func ExtractFloat64Values(arr *array.Float64) []*float64

+ func ExtractInt64Values(arr *array.Int64) []*int64

+ func ExtractStringValues(arr *array.String) []*string

+ func FilterBetween(ctx context.Context, arr arrow.Array, lower, upper interface{}) (arrow.Array, error)

+ func FilterByMask(ctx context.Context, arr arrow.Array, mask *array.Boolean) (arrow.Array, error)

+ func FilterEqual(ctx context.Context, arr arrow.Array, value interface{}) (arrow.Array, error)

+ func FilterGreaterEqual(ctx context.Context, arr arrow.Array, value interface{}) (arrow.Array, error)

+ func FilterGreaterThan(ctx context.Context, arr arrow.Array, value interface{}) (arrow.Array, error)

+ func FilterIn(ctx context.Context, arr arrow.Array, values arrow.Array) (arrow.Array, error)

+ func FilterIsMultipleOf(ctx context.Context, arr arrow.Array, value interface{}) (arrow.Array, error)

+ func FilterLessEqual(ctx context.Context, arr arrow.Array, value interface{}) (arrow.Array, error)

+ func FilterLessThan(ctx context.Context, arr arrow.Array, value interface{}) (arrow.Array, error)

+ func FilterNotEqual(ctx context.Context, arr arrow.Array, value interface{}) (arrow.Array, error)

+ func FilterNotNull(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Ln(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Log10(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Log2(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Max(ctx context.Context, arr arrow.Array) (scalar.Scalar, error)

+ func Mean(ctx context.Context, arr arrow.Array) (scalar.Scalar, error)

+ func Median(ctx context.Context, arr arrow.Array) (scalar.Scalar, error)

+ func Min(ctx context.Context, arr arrow.Array) (scalar.Scalar, error)

+ func Multiply(ctx context.Context, left, right arrow.Array) (arrow.Array, error)

+ func MultiplyScalar(ctx context.Context, arr arrow.Array, val interface{}) (arrow.Array, error)

+ func Negate(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func NthElement(ctx context.Context, arr arrow.Array, n int64, order SortOrder) (scalar.Scalar, error)

+ func Power(ctx context.Context, base, exponent arrow.Array) (arrow.Array, error)

+ func PowerScalar(ctx context.Context, arr arrow.Array, exponent interface{}) (arrow.Array, error)

+ func Quantile(ctx context.Context, arr arrow.Array, q float64) (scalar.Scalar, error)

+ func Rank(ctx context.Context, arr arrow.Array, order SortOrder) (arrow.Array, error)

+ func Round(ctx context.Context, arr arrow.Array, nDigits int64) (arrow.Array, error)

+ func Sign(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Sin(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Sort(ctx context.Context, arr arrow.Array, order SortOrder) (arrow.Array, error)

+ func SortIndicesWithOrder(ctx context.Context, arr arrow.Array, order SortOrder) (*array.Int64, error)

+ func StandardDeviation(ctx context.Context, arr arrow.Array) (float64, error)

+ func Subtract(ctx context.Context, left, right arrow.Array) (arrow.Array, error)

+ func SubtractScalar(ctx context.Context, arr arrow.Array, val interface{}) (arrow.Array, error)

+ func Sum(ctx context.Context, arr arrow.Array) (scalar.Scalar, error)

+ func Take(ctx context.Context, arr arrow.Array, indices arrow.Array) (arrow.Array, error)

+ func TakeWithIndices(ctx context.Context, arr arrow.Array, indices *array.Int64) (arrow.Array, error)

+ func Tan(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Unique(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func UniqueValues(ctx context.Context, arr arrow.Array) (arrow.Array, error)

+ func Variance(ctx context.Context, arr arrow.Array) (float64, error)

+ type MinMaxResult struct

+ Max scalar.Scalar

+ Min scalar.Scalar

+ func MinMax(ctx context.Context, arr arrow.Array) (*MinMaxResult, error)

+ type QuantileOpts struct

+ Interpolation string

+ Quantiles []float64

+ func (o *QuantileOpts) TypeName() string

+ type SortIndicesOptions struct

+ Descending bool

+ func (o *SortIndicesOptions) TypeName() string

+ type SortOrder int

+ const Ascending

+ const Descending

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