plain

package

v0.0.0-...-5d42db8 Latest Latest Go to latest Published: Jul 12, 2023 License: Apache-2.0 Imports: 8 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/segmentio/parquet-go

Links

Open Source Insights

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 ¶

View Source

const (
	ByteArrayLengthSize = 4
	MaxByteArrayLength  = math.MaxInt32
)

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

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