Versions in this module Expand all Collapse all v0 v0.7.2 Jan 12, 2022 Changes in this version + func BoolType(se *sch.SchemaElement) + func Float32Type(se *sch.SchemaElement) + func Float64Type(se *sch.SchemaElement) + func Gzip(p *ParquetWriter) error + func Int32Type(se *sch.SchemaElement) + func Int64Type(se *sch.SchemaElement) + func MaxPageSize(m int) func(*ParquetWriter) error + func Snappy(p *ParquetWriter) error + func StringType(se *sch.SchemaElement) + func Uint32Type(se *sch.SchemaElement) + func Uint64Type(se *sch.SchemaElement) + func Uncompressed(p *ParquetWriter) error + type BoolField struct + func NewBoolField(read func(r Message) bool, write func(r *Message, vals []bool), path []string, ...) *BoolField + func (f *BoolField) Add(r Message) + func (f *BoolField) Levels() ([]uint8, []uint8) + func (f *BoolField) Read(r io.ReadSeeker, pg parquet.Page) error + func (f *BoolField) Scan(r *Message) + func (f *BoolField) Schema() parquet.Field + func (f *BoolField) Write(w io.Writer, meta *parquet.Metadata) error + type BoolOptionalField struct + func NewBoolOptionalField(...) *BoolOptionalField + func (f *BoolOptionalField) Add(r Message) + func (f *BoolOptionalField) Levels() ([]uint8, []uint8) + func (f *BoolOptionalField) Read(r io.ReadSeeker, pg parquet.Page) error + func (f *BoolOptionalField) Scan(r *Message) + func (f *BoolOptionalField) Schema() parquet.Field + func (f *BoolOptionalField) Write(w io.Writer, meta *parquet.Metadata) error + type Field interface + Add func(r Message) + Levels func() ([]uint8, []uint8) + Name func() string + Read func(r io.ReadSeeker, pg parquet.Page) error + Scan func(r *Message) + Schema func() parquet.Field + Write func(w io.Writer, meta *parquet.Metadata) error + func Fields(compression compression) []Field + type Float32Field struct + func NewFloat32Field(read func(r Message) float32, write func(r *Message, vals []float32), ...) *Float32Field + func (f *Float32Field) Add(r Message) + func (f *Float32Field) Levels() ([]uint8, []uint8) + func (f *Float32Field) Read(r io.ReadSeeker, pg parquet.Page) error + func (f *Float32Field) Scan(r *Message) + func (f *Float32Field) Schema() parquet.Field + func (f *Float32Field) Write(w io.Writer, meta *parquet.Metadata) error + type Float32OptionalField struct + func NewFloat32OptionalField(...) *Float32OptionalField + func (f *Float32OptionalField) Add(r Message) + func (f *Float32OptionalField) Levels() ([]uint8, []uint8) + func (f *Float32OptionalField) Read(r io.ReadSeeker, pg parquet.Page) error + func (f *Float32OptionalField) Scan(r *Message) + func (f *Float32OptionalField) Schema() parquet.Field + func (f *Float32OptionalField) Write(w io.Writer, meta *parquet.Metadata) error + type Float64Field struct + func NewFloat64Field(read func(r Message) float64, write func(r *Message, vals []float64), ...) *Float64Field + func (f *Float64Field) Add(r Message) + func (f *Float64Field) Levels() ([]uint8, []uint8) + func (f *Float64Field) Read(r io.ReadSeeker, pg parquet.Page) error + func (f *Float64Field) Scan(r *Message) + func (f *Float64Field) Schema() parquet.Field + func (f *Float64Field) Write(w io.Writer, meta *parquet.Metadata) error + type Float64OptionalField struct + func NewFloat64OptionalField(...) *Float64OptionalField + func (f *Float64OptionalField) Add(r Message) + func (f *Float64OptionalField) Levels() ([]uint8, []uint8) + func (f *Float64OptionalField) Read(r io.ReadSeeker, pg parquet.Page) error + func (f *Float64OptionalField) Scan(r *Message) + func (f *Float64OptionalField) Schema() parquet.Field + func (f *Float64OptionalField) Write(w io.Writer, meta *parquet.Metadata) error + type Int32Field struct + func NewInt32Field(read func(r Message) int32, write func(r *Message, vals []int32), ...) *Int32Field + func (f *Int32Field) Add(r Message) + func (f *Int32Field) Levels() ([]uint8, []uint8) + func (f *Int32Field) Read(r io.ReadSeeker, pg parquet.Page) error + func (f *Int32Field) Scan(r *Message) + func (f *Int32Field) Schema() parquet.Field + func (f *Int32Field) Write(w io.Writer, meta *parquet.Metadata) error + type Int32OptionalField struct + func NewInt32OptionalField(...) *Int32OptionalField + func (f *Int32OptionalField) Add(r Message) + func (f *Int32OptionalField) Levels() ([]uint8, []uint8) + func (f *Int32OptionalField) Read(r io.ReadSeeker, pg parquet.Page) error + func (f *Int32OptionalField) Scan(r *Message) + func (f *Int32OptionalField) Schema() parquet.Field + func (f *Int32OptionalField) Write(w io.Writer, meta *parquet.Metadata) error + type Int64Field struct + func NewInt64Field(read func(r Message) int64, write func(r *Message, vals []int64), ...) *Int64Field + func (f *Int64Field) Add(r Message) + func (f *Int64Field) Levels() ([]uint8, []uint8) + func (f *Int64Field) Read(r io.ReadSeeker, pg parquet.Page) error + func (f *Int64Field) Scan(r *Message) + func (f *Int64Field) Schema() parquet.Field + func (f *Int64Field) Write(w io.Writer, meta *parquet.Metadata) error + type Int64OptionalField struct + func NewInt64OptionalField(...) *Int64OptionalField + func (f *Int64OptionalField) Add(r Message) + func (f *Int64OptionalField) Levels() ([]uint8, []uint8) + func (f *Int64OptionalField) Read(r io.ReadSeeker, pg parquet.Page) error + func (f *Int64OptionalField) Scan(r *Message) + func (f *Int64OptionalField) Schema() parquet.Field + func (f *Int64OptionalField) Write(w io.Writer, meta *parquet.Metadata) error + type Levels struct + Defs []uint8 + Name string + Reps []uint8 + type ParquetReader struct + func NewParquetReader(r io.ReadSeeker, opts ...func(*ParquetReader)) (*ParquetReader, error) + func (p *ParquetReader) Error() error + func (p *ParquetReader) Levels() []Levels + func (p *ParquetReader) Next() bool + func (p *ParquetReader) Rows() int64 + func (p *ParquetReader) Scan(x *Message) + type ParquetWriter struct + func NewParquetWriter(w io.Writer, opts ...func(*ParquetWriter) error) (*ParquetWriter, error) + func (p *ParquetWriter) Add(rec Message) + func (p *ParquetWriter) Close() error + func (p *ParquetWriter) Write() error + type StringField struct + func NewStringField(read func(r Message) string, write func(r *Message, vals []string), ...) *StringField + func (f *StringField) Add(r Message) + func (f *StringField) Levels() ([]uint8, []uint8) + func (f *StringField) Read(r io.ReadSeeker, pg parquet.Page) error + func (f *StringField) Scan(r *Message) + func (f *StringField) Schema() parquet.Field + func (f *StringField) Write(w io.Writer, meta *parquet.Metadata) error + type StringOptionalField struct + func NewStringOptionalField(...) *StringOptionalField + func (f *StringOptionalField) Add(r Message) + func (f *StringOptionalField) Levels() ([]uint8, []uint8) + func (f *StringOptionalField) Read(r io.ReadSeeker, pg parquet.Page) error + func (f *StringOptionalField) Scan(r *Message) + func (f *StringOptionalField) Schema() parquet.Field + func (f *StringOptionalField) Write(w io.Writer, meta *parquet.Metadata) error