Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

coldata

package

Go to main page

Versions in this module

v0

v0.25.2

Jun 5, 2025

Changes in this version

type ColumnFactory

+ MakeColumns func(columns []Column, t *types.T, length int)

type DatumVec

+ SetType func(t interface{})

type Vec

+ func NewVec(t *types.T, length int, factory ColumnFactory) *Vec

v0.23.2

Feb 12, 2024

Changes in this version

+ const BytesMaxInlineLength

+ const DefaultColdataBatchSize

+ const ElementSize

+ const FlatBytesOverhead

+ const MaxBatchSize

+ var GetBatchMemSize func(Batch) int64

+ var VecsToStringWithRowPrefix func(vecs []Vec, length int, sel []int, prefix string) []string

+ var ZeroBatch = &zeroBatch

+ func AssertEquivalentBatches(t testingT, expected, actual Batch)

+ func BatchSize() int

+ func GetValueAt(v Vec, rowIdx int) interface

+ func ProportionalSize(v Vec, length int64) int64

+ func ResetIfBytesLike(v Vec)

+ func SetBatchSizeForTests(newBatchSize int) error

+ func SetValueAt(v Vec, elem interface{}, rowIdx int)

+ type Batch interface

+ AppendCol func(Vec)

+ Capacity func() int

+ ColVec func(i int) Vec

+ ColVecs func() []Vec

+ Length func() int

+ ReplaceCol func(Vec, int)

+ Reset func(typs []*types.T, length int, factory ColumnFactory)

+ ResetInternalBatch func()

+ Selection func() []int

+ SetLength func(int)

+ SetSelection func(bool)

+ String func() string

+ Width func() int

+ func NewMemBatch(typs []*types.T, factory ColumnFactory) Batch

+ func NewMemBatchNoCols(typs []*types.T, capacity int) Batch

+ func NewMemBatchWithCapacity(typs []*types.T, capacity int, factory ColumnFactory) Batch

+ type Bools []bool

+ func (c Bools) CopySlice(src Bools, destIdx, srcStartIdx, srcEndIdx int)

+ func (c Bools) Get(idx int) bool

+ func (c Bools) Len() int

+ func (c Bools) Set(idx int, val bool)

+ func (c Bools) Window(start, end int) Bools

+ type Bytes struct

+ func NewBytes(n int) *Bytes

+ func (b *Bytes) Abbreviated() []uint64

+ func (b *Bytes) AppendSlice(src *Bytes, destIdx, srcStartIdx, srcEndIdx int)

+ func (b *Bytes) Copy(src *Bytes, destIdx, srcIdx int)

+ func (b *Bytes) CopySlice(src *Bytes, destIdx, srcStartIdx, srcEndIdx int)

+ func (b *Bytes) Deserialize(data []byte, offsets []int32)

+ func (b *Bytes) ElemSize(idx int) int64

+ func (b *Bytes) Get(i int) []byte

+ func (b *Bytes) Len() int

+ func (b *Bytes) ProportionalSize(n int64) int64

+ func (b *Bytes) Reset()

+ func (b *Bytes) Serialize(n int, dataScratch []byte, offsetsScratch []int32) ([]byte, []int32)

+ func (b *Bytes) Set(i int, v []byte)

+ func (b *Bytes) Size() int64

+ func (b *Bytes) String() string

+ func (b *Bytes) Window(start, end int) *Bytes

+ type Column interface

+ Len func() int

+ type ColumnFactory interface

+ MakeColumn func(t *types.T, length int) Column

+ var StandardColumnFactory ColumnFactory = &defaultColumnFactory{}

+ type Datum interface

+ type DatumVec interface

+ AppendSlice func(src DatumVec, destIdx, srcStartIdx, srcEndIdx int)

+ AppendVal func(v Datum)

+ Cap func() int

+ CopySlice func(src DatumVec, destIdx, srcStartIdx, srcEndIdx int)

+ Get func(i int) Datum

+ Len func() int

+ MarshalAt func(appendTo []byte, i int) ([]byte, error)

+ Set func(i int, v Datum)

+ SetEvalCtx func(evalCtx interface{})

+ SetLength func(l int)

+ Size func(startIdx int) int64

+ UnmarshalTo func(i int, b []byte) error

+ Window func(start, end int) DatumVec

+ type Decimals []apd.Decimal

+ func (c Decimals) CopySlice(src Decimals, destIdx, srcStartIdx, srcEndIdx int)

+ func (c Decimals) Get(idx int) apd.Decimal

+ func (c Decimals) Len() int

+ func (c Decimals) Set(idx int, val apd.Decimal)

+ func (c Decimals) Window(start, end int) Decimals

+ type Durations []duration.Duration

+ func (c Durations) CopySlice(src Durations, destIdx, srcStartIdx, srcEndIdx int)

+ func (c Durations) Get(idx int) duration.Duration

+ func (c Durations) Len() int

+ func (c Durations) Set(idx int, val duration.Duration)

+ func (c Durations) Window(start, end int) Durations

+ type Float64s []float64

+ func (c Float64s) CopySlice(src Float64s, destIdx, srcStartIdx, srcEndIdx int)

+ func (c Float64s) Get(idx int) float64

+ func (c Float64s) Len() int

+ func (c Float64s) Set(idx int, val float64)

+ func (c Float64s) Window(start, end int) Float64s

+ type Int16s []int16

+ func (c Int16s) CopySlice(src Int16s, destIdx, srcStartIdx, srcEndIdx int)

+ func (c Int16s) Get(idx int) int16

+ func (c Int16s) Len() int

+ func (c Int16s) Set(idx int, val int16)

+ func (c Int16s) Window(start, end int) Int16s

+ type Int32s []int32

+ func (c Int32s) CopySlice(src Int32s, destIdx, srcStartIdx, srcEndIdx int)

+ func (c Int32s) Get(idx int) int32

+ func (c Int32s) Len() int

+ func (c Int32s) Set(idx int, val int32)

+ func (c Int32s) Window(start, end int) Int32s

+ type Int64s []int64

+ func (c Int64s) CopySlice(src Int64s, destIdx, srcStartIdx, srcEndIdx int)

+ func (c Int64s) Get(idx int) int64

+ func (c Int64s) Len() int

+ func (c Int64s) Set(idx int, val int64)

+ func (c Int64s) Window(start, end int) Int64s

+ type JSONs struct

+ func NewJSONs(n int) *JSONs

+ func (js *JSONs) AppendSlice(src *JSONs, destIdx, srcStartIdx, srcEndIdx int)

+ func (js *JSONs) Copy(src *JSONs, destIdx, srcIdx int)

+ func (js *JSONs) CopySlice(src *JSONs, destIdx, srcStartIdx, srcEndIdx int)

+ func (js *JSONs) Get(i int) json.JSON

+ func (js *JSONs) Set(i int, j json.JSON)

+ func (js *JSONs) String() string

+ func (js *JSONs) Window(start, end int) *JSONs

+ type MemBatch struct

+ func (m *MemBatch) AppendCol(col Vec)

+ func (m *MemBatch) Capacity() int

+ func (m *MemBatch) ColVec(i int) Vec

+ func (m *MemBatch) ColVecs() []Vec

+ func (m *MemBatch) Length() int

+ func (m *MemBatch) ReplaceCol(col Vec, colIdx int)

+ func (m *MemBatch) Reset(typs []*types.T, length int, factory ColumnFactory)

+ func (m *MemBatch) ResetInternalBatch()

+ func (m *MemBatch) Selection() []int

+ func (m *MemBatch) SetLength(length int)

+ func (m *MemBatch) SetSelection(b bool)

+ func (m *MemBatch) String() string

+ func (m *MemBatch) Width() int

+ type Nulls struct

+ func NewNulls(len int) Nulls

+ func (n *Nulls) Copy(other *Nulls)

+ func (n *Nulls) MaybeHasNulls() bool

+ func (n *Nulls) NullAt(i int) bool

+ func (n *Nulls) NullAtChecked(i int) bool

+ func (n *Nulls) NullBitmap() []byte

+ func (n *Nulls) SetNull(i int)

+ func (n *Nulls) SetNullBitmap(bm []byte, size int)

+ func (n *Nulls) SetNullRange(startIdx int, endIdx int)

+ func (n *Nulls) SetNulls()

+ func (n *Nulls) Slice(start int, end int) Nulls

+ func (n *Nulls) Truncate(start int)

+ func (n *Nulls) UnsetNull(i int)

+ func (n *Nulls) UnsetNullRange(startIdx, endIdx int)

+ func (n *Nulls) UnsetNulls()

+ func (n *Nulls) UnsetNullsAfter(idx int)

+ func (n Nulls) Or(n2 Nulls) Nulls

+ type SliceArgs struct

+ DestIdx int

+ Sel []int

+ Src Vec

+ SrcEndIdx int

+ SrcStartIdx int

+ type Times []time.Time

+ func (c Times) CopySlice(src Times, destIdx, srcStartIdx, srcEndIdx int)

+ func (c Times) Get(idx int) time.Time

+ func (c Times) Len() int

+ func (c Times) Set(idx int, val time.Time)

+ func (c Times) Window(start, end int) Times

+ type TypedVecs struct

+ BoolCols []Bools

+ BytesCols []*Bytes

+ ColsMap []int

+ DatumCols []DatumVec

+ DecimalCols []Decimals

+ Float64Cols []Float64s

+ Int16Cols []Int16s

+ Int32Cols []Int32s

+ Int64Cols []Int64s

+ IntervalCols []Durations

+ JSONCols []*JSONs

+ Nulls []*Nulls

+ TimestampCols []Times

+ Vecs []Vec

+ func (v *TypedVecs) Reset()

+ func (v *TypedVecs) SetBatch(batch Batch)

+ type Vec interface

+ Append func(SliceArgs)

+ Bool func() Bools

+ Bytes func() *Bytes

+ CanonicalTypeFamily func() types.Family

+ Capacity func() int

+ Col func() Column

+ Copy func(SliceArgs)

+ CopyWithReorderedSource func(src Vec, sel, order []int)

+ Datum func() DatumVec

+ Decimal func() Decimals

+ Float64 func() Float64s

+ Int16 func() Int16s

+ Int32 func() Int32s

+ Int64 func() Int64s

+ Interval func() Durations

+ JSON func() *JSONs

+ Length func() int

+ MaybeHasNulls func() bool

+ Nulls func() *Nulls

+ SetCol func(Column)

+ SetNulls func(Nulls)

+ TemplateType func() []interface{}

+ Timestamp func() Times

+ Type func() *types.T

+ Window func(start int, end int) Vec

+ func NewMemColumn(t *types.T, length int, factory ColumnFactory) Vec