types

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 ParquetTypeToGoReflectType(pT *parquet.Type, cT *parquet.ConvertedType, rT *parquet.FieldRepetitionType) reflect.Type
• 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 ParquetTypeToGoReflectType

func ParquetTypeToGoReflectType(pT *parquet.Type, cT *parquet.ConvertedType, rT *parquet.FieldRepetitionType) reflect.Type

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)