Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

utils

package

Go to main page

Versions in this module

v15

v15.0.2

Mar 13, 2024

v15.0.1

Feb 23, 2024

v15.0.0

Jan 16, 2024

Changes in this version

+ const MaxIndexType

+ const MaxValuesPerLiteralRun

+ const MinIndexType

+ func BytesToBools(in []byte, out []bool)

+ func MaxRLEBufferSize(width, numValues int) int

+ func MinRLEBufferSize(bitWidth int) int

+ type BitReader struct

+ func NewBitReader(r reader) *BitReader

+ func (b *BitReader) CurOffset() int64

+ func (b *BitReader) GetAligned(nbytes int, v interface{}) bool

+ func (b *BitReader) GetBatch(bits uint, out []uint64) (int, error)

+ func (b *BitReader) GetBatchBools(out []bool) (int, error)

+ func (b *BitReader) GetBatchIndex(bits uint, out []IndexType) (i int, err error)

+ func (b *BitReader) GetValue(width int) (uint64, bool)

+ func (b *BitReader) GetVlqInt() (uint64, bool)

+ func (b *BitReader) GetZigZagVlqInt() (int64, bool)

+ func (b *BitReader) ReadByte() (byte, error)

+ func (b *BitReader) Reset(r reader)

+ type BitWriter struct

+ func NewBitWriter(w WriterAtWithLen) *BitWriter

+ func (b *BitWriter) Clear()

+ func (b *BitWriter) Flush(align bool)

+ func (b *BitWriter) SkipBytes(nbytes int) (int, error)

+ func (b *BitWriter) WriteAligned(val uint64, nbytes int) bool

+ func (b *BitWriter) WriteAt(val []byte, off int64) (int, error)

+ func (b *BitWriter) WriteValue(v uint64, nbits uint) error

+ func (b *BitWriter) WriteVlqInt(v uint64) bool

+ func (b *BitWriter) WriteZigZagVlqInt(v int64) bool

+ func (b *BitWriter) Written() int

+ type BitmapWriter interface

+ AppendBools func(in []bool) int

+ AppendWord func(word uint64, nbits int64)

+ Clear func()

+ Finish func()

+ Next func()

+ Pos func() int

+ Reset func(start, length int)

+ Set func()

+ func NewBitmapWriter(bitmap []byte, start, length int) BitmapWriter

+ func NewFirstTimeBitmapWriter(buf []byte, start, length int64) BitmapWriter

+ type DictionaryConverter interface

+ Copy func(interface{}, []IndexType) error

+ Fill func(interface{}, IndexType) error

+ FillZero func(interface{})

+ IsValid func(...IndexType) bool

+ type IndexType = int32

+ type RleDecoder struct

+ func NewRleDecoder(data *bytes.Reader, width int) *RleDecoder

+ func (r *RleDecoder) GetBatch(values []uint64) int

+ func (r *RleDecoder) GetBatchSpaced(vals []uint64, nullcount int, validBits []byte, validBitsOffset int64) (int, error)

+ func (r *RleDecoder) GetBatchWithDict(dc DictionaryConverter, vals interface{}) (int, error)

+ func (r *RleDecoder) GetBatchWithDictByteArray(dc DictionaryConverter, vals []parquet.ByteArray) (int, error)

+ func (r *RleDecoder) GetBatchWithDictFixedLenByteArray(dc DictionaryConverter, vals []parquet.FixedLenByteArray) (int, error)

+ func (r *RleDecoder) GetBatchWithDictFloat32(dc DictionaryConverter, vals []float32) (int, error)

+ func (r *RleDecoder) GetBatchWithDictFloat64(dc DictionaryConverter, vals []float64) (int, error)

+ func (r *RleDecoder) GetBatchWithDictInt32(dc DictionaryConverter, vals []int32) (int, error)

+ func (r *RleDecoder) GetBatchWithDictInt64(dc DictionaryConverter, vals []int64) (int, error)

+ func (r *RleDecoder) GetBatchWithDictInt96(dc DictionaryConverter, vals []parquet.Int96) (int, error)

+ func (r *RleDecoder) GetBatchWithDictSpaced(dc DictionaryConverter, vals interface{}, nullCount int, validBits []byte, ...) (int, error)

+ func (r *RleDecoder) GetBatchWithDictSpacedByteArray(dc DictionaryConverter, vals []parquet.ByteArray, nullCount int, ...) (totalProcessed int, err error)

+ func (r *RleDecoder) GetBatchWithDictSpacedFixedLenByteArray(dc DictionaryConverter, vals []parquet.FixedLenByteArray, nullCount int, ...) (totalProcessed int, err error)

+ func (r *RleDecoder) GetBatchWithDictSpacedFloat32(dc DictionaryConverter, vals []float32, nullCount int, validBits []byte, ...) (totalProcessed int, err error)

+ func (r *RleDecoder) GetBatchWithDictSpacedFloat64(dc DictionaryConverter, vals []float64, nullCount int, validBits []byte, ...) (totalProcessed int, err error)

+ func (r *RleDecoder) GetBatchWithDictSpacedInt32(dc DictionaryConverter, vals []int32, nullCount int, validBits []byte, ...) (totalProcessed int, err error)

+ func (r *RleDecoder) GetBatchWithDictSpacedInt64(dc DictionaryConverter, vals []int64, nullCount int, validBits []byte, ...) (totalProcessed int, err error)

+ func (r *RleDecoder) GetBatchWithDictSpacedInt96(dc DictionaryConverter, vals []parquet.Int96, nullCount int, validBits []byte, ...) (totalProcessed int, err error)

+ func (r *RleDecoder) GetValue() (uint64, bool)

+ func (r *RleDecoder) Next() bool

+ func (r *RleDecoder) Reset(data *bytes.Reader, width int)

+ type RleEncoder struct

+ BitWidth int

+ func NewRleEncoder(w WriterAtWithLen, width int) *RleEncoder

+ func (r *RleEncoder) Clear()

+ func (r *RleEncoder) Flush() int

+ func (r *RleEncoder) Put(value uint64) error

+ type TellWrapper struct

+ func (w *TellWrapper) Close() error

+ func (w *TellWrapper) Tell() int64

+ func (w *TellWrapper) Write(p []byte) (n int, err error)

+ type WriteCloserTell interface

+ Tell func() int64

+ type WriterAtBuffer struct

+ func (w *WriterAtBuffer) Len() int

+ func (w *WriterAtBuffer) Reserve(nbytes int)

+ func (w *WriterAtBuffer) WriteAt(p []byte, off int64) (n int, err error)

+ type WriterAtWithLen interface

+ Len func() int

+ Reserve func(int)

+ func NewWriterAtBuffer(buf []byte) WriterAtWithLen

+ type WriterTell interface

+ Tell func() int64

Other modules containing this package

github.com/apache/arrow/go/v10

github.com/apache/arrow/go/v11

github.com/apache/arrow/go/v12

github.com/apache/arrow/go/v13

github.com/apache/arrow/go/v14

github.com/apache/arrow/go/v16

github.com/apache/arrow/go/v6

github.com/apache/arrow/go/v7

github.com/apache/arrow/go/v8

github.com/apache/arrow/go/v9