storage

Documentation

Index

• 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
  • 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

Functions

func ParquetGuessCapiType

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

func ParquetReadBool

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

func ParquetReadDateTime

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

func ParquetReadDecimal2

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

func ParquetReadFloat

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

func ParquetReadInt

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

func ParquetReadString

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

func ParquetWriterDecimal2

func ParquetWriterDecimal2(dec decimal.Decimal) interface{}

func ParquetWriterMilliTs

func ParquetWriterMilliTs(t time.Time) interface{}

Types

type ParquetWriter

type ParquetWriter struct {
	FileWriter *gp.FileWriter
	StoreMap   map[string]*gp.ColumnStore // TODO: consider using w.FileWriter.GetColumnByName() instead and abandon ParquetWriter
}

func NewParquetWriter

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

func (*ParquetWriter) AddColumn

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

func (*ParquetWriter) Close

func (w *ParquetWriter) Close() error