ParquetType

Documentation

Index

• func GoTypeToParquetType(src interface{}, pT *parquet.Type, cT *parquet.ConvertedType) interface{}
• func JSONTypeToParquetType(val reflect.Value, pT *parquet.Type, cT *parquet.ConvertedType, length int, ...) interface{}
• func ParquetTypeToGoType(src interface{}, pT *parquet.Type, cT *parquet.ConvertedType) interface{}
• func StrIntToBinary(num string, order string, length int, signed bool) string
• func StrToParquetType(s string, pT *parquet.Type, cT *parquet.ConvertedType, length int, scale int) interface{}
• func TypeNameToParquetType(name string, baseName string) (*parquet.Type, *parquet.ConvertedType)

Functions

func GoTypeToParquetType

func GoTypeToParquetType(src interface{}, pT *parquet.Type, cT *parquet.ConvertedType) interface{}

func JSONTypeToParquetType

func JSONTypeToParquetType(val reflect.Value, pT *parquet.Type, cT *parquet.ConvertedType, length int, scale int) interface{}

func ParquetTypeToGoType

func ParquetTypeToGoType(src interface{}, pT *parquet.Type, cT *parquet.ConvertedType) interface{}

func StrIntToBinary

func StrIntToBinary(num string, order string, length int, signed bool) string

order=LittleEndian or BigEndian; length is byte num

func StrToParquetType

func StrToParquetType(s string, pT *parquet.Type, cT *parquet.ConvertedType, length int, scale int) interface{}

Scan a string to parquet value; length and scale just for decimal

func TypeNameToParquetType

func TypeNameToParquetType(name string, baseName string) (*parquet.Type, *parquet.ConvertedType)