encoding

package
v1.4.0 Latest Latest
Warning

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

Go to latest
Published: Sep 17, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BinaryReadFLOAT32

func BinaryReadFLOAT32(r io.Reader, nums []interface{}) error

func BinaryReadFLOAT64

func BinaryReadFLOAT64(r io.Reader, nums []interface{}) error

func BinaryReadINT32

func BinaryReadINT32(r io.Reader, nums []interface{}) error

func BinaryReadINT64

func BinaryReadINT64(r io.Reader, nums []interface{}) error

func BinaryWriteFLOAT32

func BinaryWriteFLOAT32(w io.Writer, nums []interface{})

func BinaryWriteFLOAT64

func BinaryWriteFLOAT64(w io.Writer, nums []interface{})

func BinaryWriteINT32

func BinaryWriteINT32(w io.Writer, nums []interface{})

func BinaryWriteINT64

func BinaryWriteINT64(w io.Writer, nums []interface{})

func ReadBitPacked

func ReadBitPacked(bytesReader *bytes.Reader, header uint64, bitWidth uint64) ([]interface{}, error)

return res is []INT64

func ReadDeltaBinaryPackedINT

func ReadDeltaBinaryPackedINT(bytesReader *bytes.Reader) ([]interface{}, error)

res is INT64

func ReadDeltaByteArray

func ReadDeltaByteArray(bytesReader *bytes.Reader) ([]interface{}, error)

func ReadDeltaLengthByteArray

func ReadDeltaLengthByteArray(bytesReader *bytes.Reader) ([]interface{}, error)

func ReadPlain

func ReadPlain(bytesReader *bytes.Reader, dataType parquet.Type, cnt uint64, bitWidth uint64) ([]interface{}, error)

func ReadPlainBOOLEAN

func ReadPlainBOOLEAN(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)

func ReadPlainBYTE_ARRAY

func ReadPlainBYTE_ARRAY(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)

func ReadPlainDOUBLE

func ReadPlainDOUBLE(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)

func ReadPlainFIXED_LEN_BYTE_ARRAY

func ReadPlainFIXED_LEN_BYTE_ARRAY(bytesReader *bytes.Reader, cnt uint64, fixedLength uint64) ([]interface{}, error)

func ReadPlainFLOAT

func ReadPlainFLOAT(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)

func ReadPlainINT32

func ReadPlainINT32(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)

func ReadPlainINT64

func ReadPlainINT64(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)

func ReadPlainINT96

func ReadPlainINT96(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)

func ReadRLE

func ReadRLE(bytesReader *bytes.Reader, header uint64, bitWidth uint64) ([]interface{}, error)

RLE return res is []INT64

func ReadRLEBitPackedHybrid

func ReadRLEBitPackedHybrid(bytesReader *bytes.Reader, bitWidth uint64, length uint64) ([]interface{}, error)

res is INT64

func ReadUnsignedVarInt

func ReadUnsignedVarInt(bytesReader *bytes.Reader) (uint64, error)

func ToInt64

func ToInt64(nums []interface{}) []int64

func WriteBitPacked

func WriteBitPacked(vals []interface{}, bitWidth int64, ifHeader bool) []byte

func WriteBitPackedDeprecated

func WriteBitPackedDeprecated(vals []interface{}, bitWidth int64) []byte

func WriteDelta

func WriteDelta(nums []interface{}) []byte

func WriteDeltaByteArray

func WriteDeltaByteArray(arrays []interface{}) []byte

func WriteDeltaINT32

func WriteDeltaINT32(nums []interface{}) []byte

func WriteDeltaINT64

func WriteDeltaINT64(nums []interface{}) []byte

func WriteDeltaLengthByteArray

func WriteDeltaLengthByteArray(arrays []interface{}) []byte

func WritePlain

func WritePlain(src []interface{}, pt parquet.Type) []byte

func WritePlainBOOLEAN

func WritePlainBOOLEAN(nums []interface{}) []byte

func WritePlainBYTE_ARRAY

func WritePlainBYTE_ARRAY(arrays []interface{}) []byte

func WritePlainDOUBLE

func WritePlainDOUBLE(nums []interface{}) []byte

func WritePlainFIXED_LEN_BYTE_ARRAY

func WritePlainFIXED_LEN_BYTE_ARRAY(arrays []interface{}) []byte

func WritePlainFLOAT

func WritePlainFLOAT(nums []interface{}) []byte

func WritePlainINT32

func WritePlainINT32(nums []interface{}) []byte

func WritePlainINT64

func WritePlainINT64(nums []interface{}) []byte

func WritePlainINT96

func WritePlainINT96(nums []interface{}) []byte

func WriteRLE

func WriteRLE(vals []interface{}, bitWidth int32, pt parquet.Type) []byte

func WriteRLEBitPackedHybrid

func WriteRLEBitPackedHybrid(vals []interface{}, bitWidths int32, pt parquet.Type) []byte

func WriteUnsignedVarInt

func WriteUnsignedVarInt(num uint64) []byte

Types

This section is empty.

Jump to

Keyboard shortcuts

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