encoding

package

v1.5.5-0...-e0b80c6 Latest Latest Go to latest Published: Dec 4, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

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/mdgraboski/parquet-go

Documentation ¶

Index ¶

func BinaryReadFLOAT32(r io.Reader, nums []interface{}) error
func BinaryReadFLOAT64(r io.Reader, nums []interface{}) error
func BinaryReadINT32(r io.Reader, nums []interface{}) error
func BinaryReadINT64(r io.Reader, nums []interface{}) error
func BinaryWriteFLOAT32(w io.Writer, nums []interface{})
func BinaryWriteFLOAT64(w io.Writer, nums []interface{})
func BinaryWriteINT32(w io.Writer, nums []interface{})
func BinaryWriteINT64(w io.Writer, nums []interface{})
func ReadBitPacked(bytesReader *bytes.Reader, header uint64, bitWidth uint64) ([]interface{}, error)
func ReadDeltaBinaryPackedINT(bytesReader *bytes.Reader) ([]interface{}, error)
func ReadDeltaByteArray(bytesReader *bytes.Reader) ([]interface{}, error)
func ReadDeltaLengthByteArray(bytesReader *bytes.Reader) ([]interface{}, error)
func ReadPlain(bytesReader *bytes.Reader, dataType parquet.Type, cnt uint64, bitWidth uint64) ([]interface{}, error)
func ReadPlainBOOLEAN(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)
func ReadPlainBYTE_ARRAY(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)
func ReadPlainDOUBLE(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)
func ReadPlainFIXED_LEN_BYTE_ARRAY(bytesReader *bytes.Reader, cnt uint64, fixedLength uint64) ([]interface{}, error)
func ReadPlainFLOAT(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)
func ReadPlainINT32(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)
func ReadPlainINT64(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)
func ReadPlainINT96(bytesReader *bytes.Reader, cnt uint64) ([]interface{}, error)
func ReadRLE(bytesReader *bytes.Reader, header uint64, bitWidth uint64) ([]interface{}, error)
func ReadRLEBitPackedHybrid(bytesReader *bytes.Reader, bitWidth uint64, length uint64) ([]interface{}, error)
func ReadUnsignedVarInt(bytesReader *bytes.Reader) (uint64, error)
func ToInt64(nums []interface{}) []int64
func WriteBitPacked(vals []interface{}, bitWidth int64, ifHeader bool) []byte
func WriteBitPackedDeprecated(vals []interface{}, bitWidth int64) []byte
func WriteDelta(nums []interface{}) []byte
func WriteDeltaByteArray(arrays []interface{}) []byte
func WriteDeltaINT32(nums []interface{}) []byte
func WriteDeltaINT64(nums []interface{}) []byte
func WriteDeltaLengthByteArray(arrays []interface{}) []byte
func WritePlain(src []interface{}, pt parquet.Type) []byte
func WritePlainBOOLEAN(nums []interface{}) []byte
func WritePlainBYTE_ARRAY(arrays []interface{}) []byte
func WritePlainDOUBLE(nums []interface{}) []byte
func WritePlainFIXED_LEN_BYTE_ARRAY(arrays []interface{}) []byte
func WritePlainFLOAT(nums []interface{}) []byte
func WritePlainINT32(nums []interface{}) []byte
func WritePlainINT64(nums []interface{}) []byte
func WritePlainINT96(nums []interface{}) []byte
func WriteRLE(vals []interface{}, bitWidth int32, pt parquet.Type) []byte
func WriteRLEBitPackedHybrid(vals []interface{}, bitWidths int32, pt parquet.Type) []byte
func WriteRLEBitPackedHybridInt32(vals []int32, bitWidths int32) []byte
func WriteRLEInt32(vals []int32, bitWidth int32) []byte
func WriteUnsignedVarInt(num uint64) []byte

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 WriteRLEBitPackedHybridInt32 ¶

func WriteRLEBitPackedHybridInt32(vals []int32, bitWidths int32) []byte

func WriteRLEInt32 ¶

func WriteRLEInt32(vals []int32, bitWidth int32) []byte

func WriteUnsignedVarInt ¶

func WriteUnsignedVarInt(num uint64) []byte

Types ¶

This section is empty.

Source Files ¶

View all Source files

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