storage

Dec 18, 2023

Changes in this version

+ type GuessedField struct

+ CapiName string

+ Format string

+ OriginalHeader string

+ Type sc.TableFieldType

+ func CsvGuessFields(filePath string, csvHeaderLineIdx int, csvFirstDataLineIdx int, ...) ([]*GuessedField, error)

+ func ParquetGuessFields(filePath string) ([]*GuessedField, error)

Jun 10, 2023

Changes in this version

+ func ParquetGuessCapiType(se *gp_parquet.SchemaElement) (sc.TableFieldType, error)

+ func ParquetReadBool(val interface{}, se *gp_parquet.SchemaElement) (bool, error)

+ func ParquetReadDateTime(val interface{}, se *gp_parquet.SchemaElement) (time.Time, error)

+ func ParquetReadDecimal2(val interface{}, se *gp_parquet.SchemaElement) (decimal.Decimal, error)

+ func ParquetReadFloat(val interface{}, se *gp_parquet.SchemaElement) (float64, error)

+ func ParquetReadInt(val interface{}, se *gp_parquet.SchemaElement) (int64, error)

+ func ParquetReadString(val interface{}, se *gp_parquet.SchemaElement) (string, error)

+ func ParquetWriterDecimal2(dec decimal.Decimal) interface

+ func ParquetWriterMilliTs(t time.Time) interface

+ type ParquetWriter struct

+ FileWriter *gp.FileWriter

+ StoreMap map[string]*gp.ColumnStore

+ func NewParquetWriter(ioWriter io.Writer, codec sc.ParquetCodecType) (*ParquetWriter, error)

+ func (w *ParquetWriter) AddColumn(name string, fieldType sc.TableFieldType) error

+ func (w *ParquetWriter) Close() error