Versions in this module Expand all Collapse all v7 v7.0.1 Jul 14, 2022 v7.0.0 Jan 29, 2022 Changes in this version + const MaxIndexType + const MaxValuesPerLiteralRun + const MinIndexType + var ToLEFloat32 = func(x float32) float32 + var ToLEFloat64 = func(x float64) float64 + var ToLEInt32 = func(x int32) int32 + var ToLEInt64 = func(x int64) int64 + var ToLEUint32 = func(x uint32) uint32 + var ToLEUint64 = func(x uint64) uint64 + func BytesToBools(in []byte, out []bool) — darwin/amd64, linux/amd64, windows/amd64 + func GetMinMaxInt32(v []int32) (min, max int32) + func GetMinMaxInt64(v []int64) (min, max int64) + func GetMinMaxUint32(v []uint32) (min, max uint32) + func GetMinMaxUint64(v []uint64) (min, max uint64) + func IsMultipleOf64(v int64) bool + func LeastSignificantBitMask(index int64) uint64 + func Max(a, b int64) int64 + func MaxBufferSize(width, numValues int) int + func MaxInt(a, b int) int + func Min(a, b int64) int64 + func MinBufferSize(bitWidth int) int + func MinInt(a, b int) int + func VisitBitBlocks(bitmap []byte, offset, length int64, visitValid func(pos int64), ...) + func VisitSetBitRuns(bitmap []byte, bitmapOffset int64, length int64, visitFn VisitFn) error + type BitBlockCount struct + Len int16 + Popcnt int16 + func (b BitBlockCount) AllSet() bool + func (b BitBlockCount) NoneSet() bool + type BitBlockCounter struct + func NewBitBlockCounter(bitmap []byte, startOffset, nbits int64) *BitBlockCounter + func (b *BitBlockCounter) NextFourWords() BitBlockCount + func (b *BitBlockCounter) NextWord() BitBlockCount + 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 BitRun struct + Len int64 + Set bool + func (b BitRun) String() string + type BitRunReader interface + NextRun func() BitRun + func NewBitRunReader(bitmap []byte, offset int64, length int64) BitRunReader + type BitWriter struct + func NewBitWriter(w io.WriterAt) *BitWriter + func (b *BitWriter) Clear() + func (b *BitWriter) Flush(align bool) + func (b *BitWriter) ReserveBytes(nbytes int) int + 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 OptionalBitBlockCounter struct + func NewOptionalBitBlockCounter(bitmap []byte, offset, length int64) *OptionalBitBlockCounter + func (obc *OptionalBitBlockCounter) NextBlock() BitBlockCount + func (obc *OptionalBitBlockCounter) NextWord() BitBlockCount + 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 io.WriterAt, width int) *RleEncoder + func (r *RleEncoder) Clear() + func (r *RleEncoder) Flush() int + func (r *RleEncoder) Put(value uint64) error + type SetBitRun struct + Length int64 + Pos int64 + func (s SetBitRun) AtEnd() bool + func (s SetBitRun) Equal(rhs SetBitRun) bool + type SetBitRunReader interface + NextRun func() SetBitRun + Reset func([]byte, int64, int64) + VisitSetBitRuns func(visitFn VisitFn) error + func NewReverseSetBitRunReader(validBits []byte, startOffset, numValues int64) SetBitRunReader + func NewSetBitRunReader(validBits []byte, startOffset, numValues int64) SetBitRunReader + type TellWrapper struct + func (w *TellWrapper) Close() error + func (w *TellWrapper) Tell() int64 + func (w *TellWrapper) Write(p []byte) (n int, err error) + type VisitFn func(pos int64, length int64) error + type WriteCloserTell interface + Tell func() int64 + type WriterAtBuffer struct + func (w *WriterAtBuffer) Len() int + func (w *WriterAtBuffer) WriteAt(p []byte, off int64) (n int, err error) + type WriterAtWithLen interface + Len 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/v15 github.com/apache/arrow/go/v16 github.com/apache/arrow/go/v6 github.com/apache/arrow/go/v8 github.com/apache/arrow/go/v9