Versions in this module Expand all Collapse all v9 v9.0.0 Jul 29, 2022 Changes in this version + const MaxIndexType + const MaxValuesPerLiteralRun + const MinIndexType + func BytesToBools(in []byte, out []bool) — darwin/amd64, linux/amd64, windows/amd64 + func MaxBufferSize(width, numValues int) int + func MinBufferSize(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 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 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 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) 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/v17 github.com/apache/arrow/go/v6 github.com/apache/arrow/go/v7 github.com/apache/arrow/go/v8
Go to main page