Documentation
¶
Index ¶
- type Chunk
- func (c *Chunk) AddFixedLenColumn(elemLen, initCap int)
- func (c *Chunk) AddInterfaceColumn()
- func (c *Chunk) AddVarLenColumn(initCap int)
- func (c *Chunk) AppendBytes(colIdx int, b []byte)
- func (c *Chunk) AppendDuration(colIdx int, dur types.Duration)
- func (c *Chunk) AppendEnum(colIdx int, enum types.Enum)
- func (c *Chunk) AppendFloat32(colIdx int, f float32)
- func (c *Chunk) AppendFloat64(colIdx int, f float64)
- func (c *Chunk) AppendInt64(colIdx int, i int64)
- func (c *Chunk) AppendJSON(colIdx int, j json.JSON)
- func (c *Chunk) AppendMyDecimal(colIdx int, dec *types.MyDecimal)
- func (c *Chunk) AppendNull(colIdx int)
- func (c *Chunk) AppendRow(colIdx int, row Row)
- func (c *Chunk) AppendSet(colIdx int, set types.Set)
- func (c *Chunk) AppendString(colIdx int, str string)
- func (c *Chunk) AppendTime(colIdx int, t types.Time)
- func (c *Chunk) AppendUint64(colIdx int, u uint64)
- func (c *Chunk) GetRow(idx int) Row
- func (c *Chunk) NumCols() int
- func (c *Chunk) NumRows() int
- func (c *Chunk) Reset()
- type Row
- func (r Row) GetBytes(colIdx int) ([]byte, bool)
- func (r Row) GetDuration(colIdx int) (types.Duration, bool)
- func (r Row) GetEnum(colIdx int) (types.Enum, bool)
- func (r Row) GetFloat32(colIdx int) (float32, bool)
- func (r Row) GetFloat64(colIdx int) (float64, bool)
- func (r Row) GetInt64(colIdx int) (int64, bool)
- func (r Row) GetJSON(colIdx int) (json.JSON, bool)
- func (r Row) GetMyDecimal(colIdx int) (*types.MyDecimal, bool)
- func (r Row) GetSet(colIdx int) (types.Set, bool)
- func (r Row) GetString(colIdx int) (string, bool)
- func (r Row) GetTime(colIdx int) (types.Time, bool)
- func (r Row) GetUint64(colIdx int) (uint64, bool)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Chunk ¶
type Chunk struct {
// contains filtered or unexported fields
}
Chunk stores multiple rows of data in Apache Arrow format. See https://arrow.apache.org/docs/memory_layout.html Values are appended in compact format and can be directly accessed without decoding. When the chunk is done processing, we can reuse the allocated memory by resetting it.
func (*Chunk) AddFixedLenColumn ¶
AddFixedLenColumn adds a fixed length column with elemLen and initial data capacity.
func (*Chunk) AddInterfaceColumn ¶
func (c *Chunk) AddInterfaceColumn()
AddInterfaceColumn adds an interface column which holds element as interface.
func (*Chunk) AddVarLenColumn ¶
AddVarLenColumn adds a variable length column with initial data capacity.
func (*Chunk) AppendBytes ¶
AppendBytes appends a bytes value to the chunk.
func (*Chunk) AppendDuration ¶
AppendDuration appends a Duration value to the chunk.
func (*Chunk) AppendEnum ¶
AppendEnum appends an Enum value to the chunk.
func (*Chunk) AppendFloat32 ¶
AppendFloat32 appends a float32 value to the chunk.
func (*Chunk) AppendFloat64 ¶
AppendFloat64 appends a float64 value to the chunk.
func (*Chunk) AppendInt64 ¶
AppendInt64 appends a int64 value to the chunk.
func (*Chunk) AppendJSON ¶
AppendJSON appends a JSON value to the chunk.
func (*Chunk) AppendMyDecimal ¶
AppendMyDecimal appends a MyDecimal value to the chunk.
func (*Chunk) AppendNull ¶
AppendNull appends a null value to the chunk.
func (*Chunk) AppendString ¶
AppendString appends a string value to the chunk.
func (*Chunk) AppendTime ¶
AppendTime appends a Time value to the chunk. TODO: change the time structure so it can be directly written to memory.
func (*Chunk) AppendUint64 ¶
AppendUint64 appends a uint64 value to the chunk.
type Row ¶
type Row struct {
// contains filtered or unexported fields
}
Row represents a row of data, can be used to assess values.
func (Row) GetDuration ¶
GetDuration returns the Duration value and isNull with the colIdx.
func (Row) GetFloat32 ¶
GetFloat32 returns the float64 value and isNull with the colIdx.
func (Row) GetFloat64 ¶
GetFloat64 returns the float64 value and isNull with the colIdx.
func (Row) GetMyDecimal ¶
GetMyDecimal returns the MyDecimal value and isNull with the colIdx.
Source Files