rle

package
v0.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 31, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package rle implements the hybrid RLE/Bit-Packed encoding employed in repetition and definition levels, dictionary indexed data pages, and boolean values in the PLAIN encoding.

https://github.com/apache/parquet-format/blob/master/Encodings.md#run-length-encoding--bit-packing-hybrid-rle--3

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Decoder

type Decoder struct {
	encoding.NotSupportedDecoder
	// contains filtered or unexported fields
}

func NewDecoder

func NewDecoder(r io.Reader) *Decoder

func (*Decoder) BitWidth

func (d *Decoder) BitWidth() int

func (*Decoder) DecodeBoolean

func (d *Decoder) DecodeBoolean(data []bool) (int, error)

func (*Decoder) DecodeInt16

func (d *Decoder) DecodeInt16(data []int16) (int, error)

func (*Decoder) DecodeInt32

func (d *Decoder) DecodeInt32(data []int32) (int, error)

func (*Decoder) DecodeInt64

func (d *Decoder) DecodeInt64(data []int64) (int, error)

func (*Decoder) DecodeInt8

func (d *Decoder) DecodeInt8(data []int8) (int, error)

func (*Decoder) Read

func (d *Decoder) Read(b []byte) (int, error)

func (*Decoder) ReadByte

func (d *Decoder) ReadByte() (byte, error)

func (*Decoder) Reset

func (d *Decoder) Reset(r io.Reader)

func (*Decoder) SetBitWidth

func (d *Decoder) SetBitWidth(bitWidth int)

type DictionaryEncoding

type DictionaryEncoding struct {
}

func (*DictionaryEncoding) CanEncode

func (e *DictionaryEncoding) CanEncode(t format.Type) bool

func (*DictionaryEncoding) Encoding

func (e *DictionaryEncoding) Encoding() format.Encoding

func (*DictionaryEncoding) NewDecoder

func (e *DictionaryEncoding) NewDecoder(r io.Reader) encoding.Decoder

func (*DictionaryEncoding) NewEncoder

func (e *DictionaryEncoding) NewEncoder(w io.Writer) encoding.Encoder

func (*DictionaryEncoding) String

func (e *DictionaryEncoding) String() string

type Encoder

type Encoder struct {
	encoding.NotSupportedEncoder
	// contains filtered or unexported fields
}

func NewEncoder

func NewEncoder(w io.Writer) *Encoder

func (*Encoder) BitWidth

func (e *Encoder) BitWidth() int

func (*Encoder) EncodeBoolean

func (e *Encoder) EncodeBoolean(data []bool) error

func (*Encoder) EncodeInt16

func (e *Encoder) EncodeInt16(data []int16) error

func (*Encoder) EncodeInt32

func (e *Encoder) EncodeInt32(data []int32) error

func (*Encoder) EncodeInt64

func (e *Encoder) EncodeInt64(data []int64) error

func (*Encoder) EncodeInt8

func (e *Encoder) EncodeInt8(data []int8) error

func (*Encoder) Reset

func (e *Encoder) Reset(w io.Writer)

func (*Encoder) SetBitWidth

func (e *Encoder) SetBitWidth(bitWidth int)

func (*Encoder) Write

func (e *Encoder) Write(b []byte) (int, error)

func (*Encoder) WriteByte

func (e *Encoder) WriteByte(b byte) error

func (*Encoder) WriteUvarint

func (e *Encoder) WriteUvarint(u uint64) (int, error)

type Encoding

type Encoding struct {
}

func (*Encoding) CanEncode

func (e *Encoding) CanEncode(t format.Type) bool

func (*Encoding) Encoding

func (e *Encoding) Encoding() format.Encoding

func (*Encoding) NewDecoder

func (e *Encoding) NewDecoder(r io.Reader) encoding.Decoder

func (*Encoding) NewEncoder

func (e *Encoding) NewEncoder(w io.Writer) encoding.Encoder

func (*Encoding) String

func (e *Encoding) String() string

Jump to

Keyboard shortcuts

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