data

Documentation

Index

• func NewRowGroup(chunks []*ColumnChunk, numRows, offset int64) *parquet.RowGroup
• func UnmarshalJSON(data []byte, tree *schema.Tree) (map[string]*Column, error)
• type Column
  • func NewColumn(parquetType parquet.Type) *Column
  • func (column *Column) AddBoolean(value bool, DL, RL int64)
  • func (column *Column) AddByteArray(value []byte, DL, RL int64)
  • func (column *Column) AddDouble(value float64, DL, RL int64)
  • func (column *Column) AddFloat(value float32, DL, RL int64)
  • func (column *Column) AddInt32(value int32, DL, RL int64)
  • func (column *Column) AddInt64(value int64, DL, RL int64)
  • func (column *Column) AddNull(DL, RL int64)
  • func (column *Column) Encode(element *schema.Element) *ColumnChunk
  • func (column *Column) Merge(column2 *Column)
  • func (column *Column) String() string
• type ColumnChunk
  • func (chunk *ColumnChunk) Data() []byte
  • func (chunk *ColumnChunk) DataLen() int64

Functions

func NewRowGroup

func NewRowGroup(chunks []*ColumnChunk, numRows, offset int64) *parquet.RowGroup

NewRowGroup creates a new row group.

func UnmarshalJSON

func UnmarshalJSON(data []byte, tree *schema.Tree) (map[string]*Column, error)

UnmarshalJSON - decodes JSON data into map of Column.

Types

type Column

type Column struct {
	// contains filtered or unexported fields
}

Column - denotes values of a column.

func NewColumn

func NewColumn(parquetType parquet.Type) *Column

NewColumn - creates new column data

func (*Column) AddBoolean

func (column *Column) AddBoolean(value bool, DL, RL int64)

AddBoolean - adds boolean value.

func (*Column) AddByteArray

func (column *Column) AddByteArray(value []byte, DL, RL int64)

AddByteArray - adds byte array value.

func (*Column) AddDouble

func (column *Column) AddDouble(value float64, DL, RL int64)

AddDouble - adds float64 value.

func (*Column) AddFloat

func (column *Column) AddFloat(value float32, DL, RL int64)

AddFloat - adds float32 value.

func (*Column) AddInt32

func (column *Column) AddInt32(value int32, DL, RL int64)

AddInt32 - adds int32 value.

func (*Column) AddInt64

func (column *Column) AddInt64(value int64, DL, RL int64)

AddInt64 - adds int64 value.

func (*Column) AddNull

func (column *Column) AddNull(DL, RL int64)

AddNull - adds nil value.

func (*Column) Encode

func (column *Column) Encode(element *schema.Element) *ColumnChunk

Encode an element.

func (*Column) Merge

func (column *Column) Merge(column2 *Column)

Merge - merges columns.

func (*Column) String

func (column *Column) String() string

type ColumnChunk

type ColumnChunk struct {
	parquet.ColumnChunk
	// contains filtered or unexported fields
}

ColumnChunk ...

func (*ColumnChunk) Data

func (chunk *ColumnChunk) Data() []byte

Data returns the data.

func (*ColumnChunk) DataLen

func (chunk *ColumnChunk) DataLen() int64

DataLen returns the length of the data.