Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlockProcess ¶
type ColumnValuesPool ¶
type ColumnValuesPool struct {
// contains filtered or unexported fields
}
func NewColumnValuesPool ¶
func NewColumnValuesPool(numCols, numRows int) *ColumnValuesPool
func (*ColumnValuesPool) Get ¶
func (c *ColumnValuesPool) Get() [][]interface{}
func (*ColumnValuesPool) Put ¶
func (c *ColumnValuesPool) Put(colTexts [][]interface{})
type ColumnValuesToBlock ¶
type ColumnValuesToBlock struct {
// contains filtered or unexported fields
}
func NewColumnValuesToBlock ¶
func NewColumnValuesToBlock(cvStream <-chan [][]interface{}, sample *data.Block) *ColumnValuesToBlock
func (*ColumnValuesToBlock) Error ¶
func (a *ColumnValuesToBlock) Error() error
func (*ColumnValuesToBlock) Finish ¶
func (a *ColumnValuesToBlock) Finish() (rowsProcessed int, err error)
type RecycleColumnValues ¶
type RecycleColumnValues func(columnValues [][]interface{})
Click to show internal directories.
Click to hide internal directories.