bow

package module

Go to main page

Versions in this module

v1

v1.0.0

Apr 7, 2023

v0

v0.19.0

Apr 7, 2023

Changes in this version

type Bow

+ ArrowRecord func() *arrow.Record

type Buffer

+ DataType Type

v0.18.0

Feb 16, 2022

Changes in this version

+ var ErrColTimeUnitNotFound = errors.New("column time unit not found in parquet metadata")

type Bow

+ GetParquetMetaColTimeUnit func(colIndex int) (time.Duration, error)

v0.17.0

Oct 27, 2021

Changes in this version

type Bow

+ func NewBowFromRecord(record array.Record) (Bow, error)

+ Apply func(colIndex int, returnType Type, fn func(interface{}) interface{}) (Bow, error)

+ Convert func(colIndex int, t Type) (Bow, error)

+ Distinct func(colIndex int) Bow

+ Filter func(fns ...RowCmp) Bow

+ MakeFilterValues func(colIndex int, values ...interface{}) RowCmp

+ WithMetadata func(metadata Metadata) Bow

type Buffer

+ func NewBufferFromData(data interface{}) Buffer

+ func (b Buffer) IsSorted() bool

+ func (b Buffer) Less(i, j int) bool

+ func (b Buffer) Swap(i, j int)

type Metadata

+ func NewMetadataFromMap(m map[string]string) Metadata

+ type RowCmp func(b Bow, i int) bool

type Type

+ func (t Type) ArrowType() arrow.DataType

v0.16.0

Sep 2, 2021

Changes in this version

+ const Boolean

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

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

+ func GenStrategyDecremental(typ Type, seed int) interface

+ func GenStrategyIncremental(typ Type, seed int) interface

+ func GenStrategyRandom(typ Type, seed int) interface

+ func GenStrategyRandomDecremental(typ Type, seed int) interface

+ func GenStrategyRandomIncremental(typ Type, seed int) interface

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

+ func IsInt64SliceSorted(col Int64Slice) bool

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

+ func ToBoolean(i interface{}) (bool, bool)

type Bow

+ ColumnIndex func(colName string) (int, error)

+ ColumnName func(colIndex int) string

+ ColumnType func(colIndex int) Type

+ Contains func(columnIndex int, value interface{}) bool

+ DropNils func(colNames ...string) (Bow, error)

+ Find func(columnIndex int, value interface{}) int

+ FindNext func(columnIndex, rowIndex int, value interface{}) int

+ GetNextRowIndex func(colIndex, rowIndex int) int

+ GetPrevFloat64 func(colIndex, rowIndex int) (value float64, resRowIndex int)

+ GetPrevFloat64s func(colIndex1, colIndex2, rowIndex int) (value1, value2 float64, resRowIndex int)

+ GetPrevInt64 func(colIndex, rowIndex int) (value int64, resRowIndex int)

+ GetPrevRowIndex func(colIndex, rowIndex int) int

+ GetPrevValue func(colIndex, rowIndex int) (value interface{}, resRowIndex int)

+ GetPrevValues func(colIndex1, colIndex2, rowIndex int) (value1, value2 interface{}, resRowIndex int)

+ GetRowsChan func() <-chan map[string]interface{}

+ Metadata func() Metadata

+ NewBufferFromCol func(colIndex int) Buffer

+ NewEmptySlice func() Bow

+ NewSeriesFromCol func(colIndex int) Series

+ RenameCol func(colIndex int, newName string) (Bow, error)

type Buffer

+ Data interface{}

+ func (b *Buffer) GetValue(i int) interface{}

+ func (b *Buffer) IsNull(rowIndex int) bool

+ func (b *Buffer) IsValid(rowIndex int) bool

+ func (b *Buffer) Len() int

+ func (b *Buffer) SetOrDropStrict(i int, value interface{})

+ type CommonRows struct

+ type GenSeriesOptions struct

+ GenStrategy GenStrategy

+ MissingData bool

+ Name string

+ NumRows int

+ Type Type

+ type GenStrategy func(typ Type, seed int) interface

+ type Int64Slice struct

+ func (p Int64Slice) Len() int

+ func (p Int64Slice) Less(i, j int) bool

+ func (p Int64Slice) Swap(i, j int)

type JSONBow

+ RowBasedData []map[string]interface{}

type Series

+ func NewGenSeries(o GenSeriesOptions) Series

+ func NewSeriesFromBuffer(name string, buf Buffer) Series

type Type

+ func GetAllTypes() []Type

v0.15.0

Aug 4, 2021

v0.14.0

Jul 20, 2021

Changes in this version

type Bow

+ SetMetadata func(key, value string) Bow

type Metadata

+ func (md *Metadata) Set(key, value string) Metadata

+ func (md *Metadata) SetMany(keys, values []string) Metadata

v0.13.0

Jun 21, 2021

Changes in this version

type Bow

+ AddCols func(series ...Series) (Bow, error)

v0.12.1

Jun 16, 2021

Changes in this version

type Metadata

+ func NewMetaWithParquetTimestampMicrosCols(keys, values []string, colNames ...string) Metadata

v0.12.0

Jun 10, 2021

Changes in this version

+ const KeyColTypeMetadata

+ var TypeBowToParquetMap = map[Type]parquet.Type

+ var TypeParquetToBowMap = map[parquet.Type]Type

type Bow

+ func NewBowFromParquet(path string, verbose bool) (Bow, error)

+ func NewBowWithMetadata(metadata Metadata, series ...Series) (Bow, error)

+ GetMetadata func() Metadata

+ WriteParquet func(path string, verbose bool) error

+ type Metadata struct

+ func NewMetadata(keys, values []string) Metadata

v0.11.0

May 17, 2021

Changes in this version

type Bow

+ Diff func(colNames ...string) (Bow, error)

v0.10.0

May 11, 2021

v0.9.0

Mar 24, 2021

Changes in this version

type Bow

+ func NewGenBow(options ...Option) (Bow, error)

+ NewValuesFromJSON func(jsonB JSONBow) error

+ type JSONBow struct

+ Data []map[string]interface{}

+ Schema JSONSchema

+ func NewJSONBow(b Bow) (res JSONBow)

+ type JSONSchema struct

+ Fields []jsonField

type Option

+ func GenColNames(colNames []string) Option

+ func GenCols(cols int) Option

+ func GenDataType(dataType Type) Option

+ func GenDataTypes(dataTypes []Type) Option

+ func GenMissingData(hasMissingData bool) Option

+ func GenRefCol(refCol int, descSort bool) Option

+ func GenRows(rows int) Option

v0.8.0

Feb 12, 2021

Changes in this version

type Bow

+ FindFirst func(colIndex int, value interface{}) (rowIndex int)

+ IsEmpty func() bool

type Type

+ func (t Type) IsSupported() bool

v0.7.3

Jan 12, 2021

Changes in this version

type Bow

+ func NewBowEmpty() Bow

+ func NewBowFromColBasedInterfaces(colNames []string, colTypes []Type, colData [][]interface{}) (Bow, error)

+ Select func(colNames ...string) (Bow, error)

+ Slice func(i, j int) Bow

v0.7.2

Sep 14, 2020

v0.7.1

Aug 20, 2020

Changes in this version

type Bow

+ SetColName func(colIndex int, newName string) (Bow, error)

v0.7.0

Aug 3, 2020

Changes in this version

+ func Int64ColIsSorted(col Int64Col) bool

type Bow

+ SortByCol func(colName string) (Bow, error)

+ type Int64Col struct

+ Indices []int

+ Valids []bool

+ Values []int64

+ func (p Int64Col) Len() int

+ func (p Int64Col) Less(i, j int) bool

+ func (p Int64Col) Swap(i, j int)

v0.6.2

Jun 2, 2020

v0.6.1

Apr 23, 2020

Changes in this version

type Bow

+ GetColumnIndex func(colName string) (int, error)

v0.6.0

Apr 22, 2020

Changes in this version

+ const Bool

+ const ErrBufferOverload

+ const Float64

+ const InputDependent

+ const Int64

+ const IteratorDependent

+ const String

+ const Unknown

+ func ToBool(i interface{}) (bool, bool)

+ func ToFloat64(i interface{}) (float64, bool)

+ func ToInt64(i interface{}) (int64, bool)

+ func ToString(i interface{}) (string, bool)

+ type Bow interface

+ Column func(i int) array.Interface

+ DropNil func(nilCols ...string) (Bow, error)

+ Equal func(Bow) bool

+ FillLinear func(refCol string, toFillCol string) (Bow, error)

+ FillMean func(colNames ...string) (Bow, error)

+ FillNext func(colNames ...string) (Bow, error)

+ FillPrevious func(colNames ...string) (Bow, error)

+ GetColNameIndex func(string) int

+ GetFloat64 func(colIndex, rowIndex int) (float64, bool)

+ GetIndex func(colName string) (int, error)

+ GetInt64 func(colIndex, rowIndex int) (int64, bool)

+ GetName func(colIndex int) (string, error)

+ GetNextFloat64 func(col, row int) (v float64, resultsRow int)

+ GetNextFloat64s func(col1, col2, row int) (v1, v2 float64, resultsRow int)

+ GetNextInt64 func(col, row int) (v int64, resultsRow int)

+ GetNextValue func(col, row int) (v interface{}, resultsRow int)

+ GetNextValues func(col1, col2, row int) (v1, v2 interface{}, resultsRow int)

+ GetPreviousFloat64 func(col, row int) (v float64, resultsRow int)

+ GetPreviousFloat64s func(col1, col2, row int) (v1, v2 float64, resultsRow int)

+ GetPreviousInt64 func(col, row int) (v int64, resultsRow int)

+ GetPreviousValue func(col, row int) (v interface{}, resultsRow int)

+ GetPreviousValues func(col1, col2, row int) (v1, v2 interface{}, resultsRow int)

+ GetRow func(rowIndex int) map[string]interface{}

+ GetType func(colIndex int) Type

+ GetValue func(colIndex, rowIndex int) interface{}

+ GetValueByName func(colName string, rowIndex int) interface{}

+ InnerJoin func(other Bow) Bow

+ IsColEmpty func(colIndex int) bool

+ IsColSorted func(colIndex int) bool

+ MarshalJSON func() ([]byte, error)

+ NewEmpty func() Bow

+ NewSlice func(i, j int) Bow

+ NewValues func(columns [][]interface{}) (bobow Bow, err error)

+ NumCols func() int

+ NumRows func() int

+ OuterJoin func(other Bow) Bow

+ Release func()

+ Retain func()

+ RowMapIter func() chan map[string]interface{}

+ Schema func() *arrow.Schema

+ SetMarshalJSONRowBased func(rowOriented bool)

+ String func() string

+ UnmarshalJSON func([]byte) error

+ func AppendBows(bows ...Bow) (bobow Bow, err error)

+ func NewBow(series ...Series) (bobow Bow, err error)

+ func NewBowFromColumnBasedInterfaces(columnsNames []string, types []Type, columns [][]interface{}) (bobow Bow, err error)

+ func NewBowFromRowBasedInterfaces(columnsNames []string, types []Type, rows [][]interface{}) (bobow Bow, err error)

+ func NewRandomBow(options ...Option) (Bow, error)

+ type Buffer struct

+ Valid []bool

+ Value interface{}

+ func NewBuffer(size int, t Type, nullable bool) Buffer

+ func NewBufferFromInterfaces(t Type, cells []interface{}) (Buffer, error)

+ func NewBufferFromInterfacesIter(t Type, length int, cells chan interface{}) (Buffer, error)

+ func (b *Buffer) SetOrDrop(i int, value interface{})

+ type Option func(*randomBowOptions)

+ func Cols(cols int) Option

+ func DataType(typ Type) Option

+ func DescSort(descSort bool) Option

+ func MissingData(missing bool) Option

+ func RefCol(refCol int) Option

+ func Rows(rows int) Option

+ type Series struct

+ Array array.Interface

+ Name string

+ func NewSeries(name string, t Type, dataArray interface{}, validArray []bool) Series

+ func NewSeriesFromInterfaces(name string, typeOf Type, cells []interface{}) (series Series, err error)

+ type Type int

+ func (t Type) Convert(i interface{}) interface{}

+ func (t Type) String() string

v0.5.1

Oct 29, 2019

v0.5.0

Oct 27, 2019

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