encoding

package

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

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/abtin/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 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 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