plain

Documentation

Overview

Package plain implements the PLAIN parquet encoding.

https://github.com/apache/parquet-format/blob/master/Encodings.md#plain-plain--0

Index

• Constants
• func AppendBoolean(b []byte, n int, v bool) []byte
• func AppendByteArray(b, v []byte) []byte
• func AppendByteArrayLength(b []byte, n int) []byte
• func AppendByteArrayString(b []byte, v string) []byte
• func AppendDouble(b []byte, v float64) []byte
• func AppendFloat(b []byte, v float32) []byte
• func AppendInt32(b []byte, v int32) []byte
• func AppendInt64(b []byte, v int64) []byte
• func AppendInt96(b []byte, v deprecated.Int96) []byte
• func Boolean(v bool) []byte
• func ByteArray(v []byte) []byte
• func ByteArrayLength(b []byte) int
• func Double(v float64) []byte
• func ErrTooLarge(length int) error
• func ErrTooShort(length int) error
• func Float(v float32) []byte
• func Int32(v int32) []byte
• func Int64(v int64) []byte
• func Int96(v deprecated.Int96) []byte
• func NextByteArray(b []byte) (v, r []byte, err error)
• func PutByteArrayLength(b []byte, n int)
• func RangeByteArray(b []byte, do func([]byte) error) (err error)
• type DictionaryEncoding
  • func (e *DictionaryEncoding) DecodeInt32(dst []int32, src []byte) ([]int32, error)
  • func (e *DictionaryEncoding) EncodeInt32(dst []byte, src []int32) ([]byte, error)
  • func (e *DictionaryEncoding) Encoding() format.Encoding
  • func (e *DictionaryEncoding) String() string
• type Encoding
  • func (e *Encoding) CanDecodeInPlace() bool
  • func (e *Encoding) DecodeBoolean(dst []byte, src []byte) ([]byte, error)
  • func (e *Encoding) DecodeByteArray(dst []byte, src []byte, offsets []uint32) ([]byte, []uint32, error)
  • func (e *Encoding) DecodeDouble(dst []float64, src []byte) ([]float64, error)
  • func (e *Encoding) DecodeFixedLenByteArray(dst []byte, src []byte, size int) ([]byte, error)
  • func (e *Encoding) DecodeFloat(dst []float32, src []byte) ([]float32, error)
  • func (e *Encoding) DecodeInt32(dst []int32, src []byte) ([]int32, error)
  • func (e *Encoding) DecodeInt64(dst []int64, src []byte) ([]int64, error)
  • func (e *Encoding) DecodeInt96(dst []deprecated.Int96, src []byte) ([]deprecated.Int96, error)
  • func (e *Encoding) EncodeBoolean(dst []byte, src []byte) ([]byte, error)
  • func (e *Encoding) EncodeByteArray(dst []byte, src []byte, offsets []uint32) ([]byte, error)
  • func (e *Encoding) EncodeDouble(dst []byte, src []float64) ([]byte, error)
  • func (e *Encoding) EncodeFixedLenByteArray(dst []byte, src []byte, size int) ([]byte, error)
  • func (e *Encoding) EncodeFloat(dst []byte, src []float32) ([]byte, error)
  • func (e *Encoding) EncodeInt32(dst []byte, src []int32) ([]byte, error)
  • func (e *Encoding) EncodeInt64(dst []byte, src []int64) ([]byte, error)
  • func (e *Encoding) EncodeInt96(dst []byte, src []deprecated.Int96) ([]byte, error)
  • func (e *Encoding) Encoding() format.Encoding
  • func (e *Encoding) EstimateDecodeByteArraySize(src []byte) int
  • func (e *Encoding) String() string

Constants

const (
	ByteArrayLengthSize = 4
	MaxByteArrayLength  = math.MaxInt32
)

Functions

func AppendBoolean

func AppendBoolean(b []byte, n int, v bool) []byte

func AppendByteArray

func AppendByteArray(b, v []byte) []byte

func AppendByteArrayLength

func AppendByteArrayLength(b []byte, n int) []byte

func AppendByteArrayString

func AppendByteArrayString(b []byte, v string) []byte

func AppendDouble

func AppendDouble(b []byte, v float64) []byte

func AppendFloat

func AppendFloat(b []byte, v float32) []byte

func AppendInt32

func AppendInt32(b []byte, v int32) []byte

func AppendInt64

func AppendInt64(b []byte, v int64) []byte

func AppendInt96

func AppendInt96(b []byte, v deprecated.Int96) []byte

func Boolean

func Boolean(v bool) []byte

func ByteArray

func ByteArray(v []byte) []byte

func ByteArrayLength

func ByteArrayLength(b []byte) int

func Double

func Double(v float64) []byte

func ErrTooLarge

func ErrTooLarge(length int) error

func ErrTooShort

func ErrTooShort(length int) error

func Float

func Float(v float32) []byte

func Int32

func Int32(v int32) []byte

func Int64

func Int64(v int64) []byte

func Int96

func Int96(v deprecated.Int96) []byte

func NextByteArray

func NextByteArray(b []byte) (v, r []byte, err error)

func PutByteArrayLength

func PutByteArrayLength(b []byte, n int)

func RangeByteArray

func RangeByteArray(b []byte, do func([]byte) error) (err error)

Types

type DictionaryEncoding

type DictionaryEncoding struct {
	encoding.NotSupported
	// contains filtered or unexported fields
}

func (*DictionaryEncoding) DecodeInt32

func (e *DictionaryEncoding) DecodeInt32(dst []int32, src []byte) ([]int32, error)

func (*DictionaryEncoding) EncodeInt32

func (e *DictionaryEncoding) EncodeInt32(dst []byte, src []int32) ([]byte, error)

func (*DictionaryEncoding) Encoding

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

func (*DictionaryEncoding) String

func (e *DictionaryEncoding) String() string

type Encoding

type Encoding struct {
	encoding.NotSupported
}

func (*Encoding) CanDecodeInPlace

func (e *Encoding) CanDecodeInPlace() bool

func (*Encoding) DecodeBoolean

func (e *Encoding) DecodeBoolean(dst []byte, src []byte) ([]byte, error)

func (*Encoding) DecodeByteArray

func (e *Encoding) DecodeByteArray(dst []byte, src []byte, offsets []uint32) ([]byte, []uint32, error)

func (*Encoding) DecodeDouble

func (e *Encoding) DecodeDouble(dst []float64, src []byte) ([]float64, error)

func (*Encoding) DecodeFixedLenByteArray

func (e *Encoding) DecodeFixedLenByteArray(dst []byte, src []byte, size int) ([]byte, error)

func (*Encoding) DecodeFloat

func (e *Encoding) DecodeFloat(dst []float32, src []byte) ([]float32, error)

func (*Encoding) DecodeInt32

func (e *Encoding) DecodeInt32(dst []int32, src []byte) ([]int32, error)

func (*Encoding) DecodeInt64

func (e *Encoding) DecodeInt64(dst []int64, src []byte) ([]int64, error)

func (*Encoding) DecodeInt96

func (e *Encoding) DecodeInt96(dst []deprecated.Int96, src []byte) ([]deprecated.Int96, error)

func (*Encoding) EncodeBoolean

func (e *Encoding) EncodeBoolean(dst []byte, src []byte) ([]byte, error)

func (*Encoding) EncodeByteArray

func (e *Encoding) EncodeByteArray(dst []byte, src []byte, offsets []uint32) ([]byte, error)

func (*Encoding) EncodeDouble

func (e *Encoding) EncodeDouble(dst []byte, src []float64) ([]byte, error)

func (*Encoding) EncodeFixedLenByteArray

func (e *Encoding) EncodeFixedLenByteArray(dst []byte, src []byte, size int) ([]byte, error)

func (*Encoding) EncodeFloat

func (e *Encoding) EncodeFloat(dst []byte, src []float32) ([]byte, error)

func (*Encoding) EncodeInt32

func (e *Encoding) EncodeInt32(dst []byte, src []int32) ([]byte, error)

func (*Encoding) EncodeInt64

func (e *Encoding) EncodeInt64(dst []byte, src []int64) ([]byte, error)

func (*Encoding) EncodeInt96

func (e *Encoding) EncodeInt96(dst []byte, src []deprecated.Int96) ([]byte, error)

func (*Encoding) Encoding

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

func (*Encoding) EstimateDecodeByteArraySize

func (e *Encoding) EstimateDecodeByteArraySize(src []byte) int

func (*Encoding) String

func (e *Encoding) String() string