Versions in this module Expand all Collapse all v1 v1.4.0 Sep 17, 2019 v1.3.5 Sep 2, 2019 v1.3.0 May 24, 2019 Changes in this version + type CSVWriter struct + func NewCSVWriter(md []string, pfile source.ParquetFile, np int64) (*CSVWriter, error) + func (self *CSVWriter) WriteString(recsi interface{}) error + type JSONWriter struct + func NewJSONWriter(jsonSchema string, pfile source.ParquetFile, np int64) (*JSONWriter, error) + type ParquetWriter struct + CheckSizeCritical int64 + CompressionType parquet.CompressionCodec + DictRecs map[string]*layout.DictRecType + Footer *parquet.FileMetaData + MarshalFunc func(src []interface{}, bgn int, end int, sh *schema.SchemaHandler) (*map[string]*layout.Table, error) + NP int64 + NumRows int64 + ObjSize int64 + Objs []interface{} + ObjsSize int64 + Offset int64 + PFile source.ParquetFile + PageSize int64 + PagesMapBuf map[string][]*layout.Page + RowGroupSize int64 + SchemaHandler *schema.SchemaHandler + Size int64 + func NewParquetWriter(pFile source.ParquetFile, obj interface{}, np int64) (*ParquetWriter, error) + func (self *ParquetWriter) Flush(flag bool) error + func (self *ParquetWriter) RenameSchema() + func (self *ParquetWriter) SetSchemaHandlerFromJSON(jsonSchema string) error + func (self *ParquetWriter) Write(src interface{}) error + func (self *ParquetWriter) WriteStop() error
Go to main page