column_handler

package
v1.1.0-alpha Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 25, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BinaryColumnHandler 

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

func NewBinaryColumnHandler 

func NewBinaryColumnHandler(name string, index int, batchSize int64) *BinaryColumnHandler

func (*BinaryColumnHandler) AppendValues 

func (th *BinaryColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*BinaryColumnHandler) GetField 

func (th *BinaryColumnHandler) GetField() arrow.Field

func (*BinaryColumnHandler) GetVariable 

func (th *BinaryColumnHandler) GetVariable() interface{}

func (*BinaryColumnHandler) SetVariable 

func (th *BinaryColumnHandler) SetVariable(row int64)

type BooleanColumnHandler 

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

func NewBooleanColumnHandler 

func NewBooleanColumnHandler(name string, index int, batchSize int64) *BooleanColumnHandler

func (*BooleanColumnHandler) AppendValues 

func (th *BooleanColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*BooleanColumnHandler) GetField 

func (th *BooleanColumnHandler) GetField() arrow.Field

func (*BooleanColumnHandler) GetVariable 

func (th *BooleanColumnHandler) GetVariable() interface{}

func (*BooleanColumnHandler) SetVariable 

func (th *BooleanColumnHandler) SetVariable(row int64)

type ColumnHandler 

type ColumnHandler interface {
	GetVariable() interface{}
	GetField() arrow.Field
	AppendValues(builder *array.RecordBuilder, rows int64)
	SetVariable(row int64)
}

func GetColumnHandler 

func GetColumnHandler(index int, column *sql.ColumnType, batchSize int64) (ColumnHandler, error)

type Float32ColumnHandler 

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

func NewFloat32ColumnHandler 

func NewFloat32ColumnHandler(name string, index int, batchSize int64) *Float32ColumnHandler

func (*Float32ColumnHandler) AppendValues 

func (th *Float32ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*Float32ColumnHandler) GetField 

func (th *Float32ColumnHandler) GetField() arrow.Field

func (*Float32ColumnHandler) GetVariable 

func (th *Float32ColumnHandler) GetVariable() interface{}

func (*Float32ColumnHandler) SetVariable 

func (th *Float32ColumnHandler) SetVariable(row int64)

type Float64ColumnHandler 

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

func NewFloat64ColumnHandler 

func NewFloat64ColumnHandler(name string, index int, batchSize int64) *Float64ColumnHandler

func (*Float64ColumnHandler) AppendValues 

func (th *Float64ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*Float64ColumnHandler) GetField 

func (th *Float64ColumnHandler) GetField() arrow.Field

func (*Float64ColumnHandler) GetVariable 

func (th *Float64ColumnHandler) GetVariable() interface{}

func (*Float64ColumnHandler) SetVariable 

func (th *Float64ColumnHandler) SetVariable(row int64)

type Int16ColumnHandler 

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

func NewInt16ColumnHandler 

func NewInt16ColumnHandler(name string, index int, batchSize int64) *Int16ColumnHandler

func (*Int16ColumnHandler) AppendValues 

func (th *Int16ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*Int16ColumnHandler) GetField 

func (th *Int16ColumnHandler) GetField() arrow.Field

func (*Int16ColumnHandler) GetVariable 

func (th *Int16ColumnHandler) GetVariable() interface{}

func (*Int16ColumnHandler) SetVariable 

func (th *Int16ColumnHandler) SetVariable(row int64)

type Int32ColumnHandler 

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

func NewInt32ColumnHandler 

func NewInt32ColumnHandler(name string, index int, batchSize int64) *Int32ColumnHandler

func (*Int32ColumnHandler) AppendValues 

func (th *Int32ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*Int32ColumnHandler) GetField 

func (th *Int32ColumnHandler) GetField() arrow.Field

func (*Int32ColumnHandler) GetVariable 

func (th *Int32ColumnHandler) GetVariable() interface{}

func (*Int32ColumnHandler) SetVariable 

func (th *Int32ColumnHandler) SetVariable(row int64)

type Int64ColumnHandler 

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

func NewInt64ColumnHandler 

func NewInt64ColumnHandler(name string, index int, batchSize int64) *Int64ColumnHandler

func (*Int64ColumnHandler) AppendValues 

func (th *Int64ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*Int64ColumnHandler) GetField 

func (th *Int64ColumnHandler) GetField() arrow.Field

func (*Int64ColumnHandler) GetVariable 

func (th *Int64ColumnHandler) GetVariable() interface{}

func (*Int64ColumnHandler) SetVariable 

func (th *Int64ColumnHandler) SetVariable(row int64)

type Int8ColumnHandler 

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

func NewInt8ColumnHandler 

func NewInt8ColumnHandler(name string, index int, batchSize int64) *Int8ColumnHandler

func (*Int8ColumnHandler) AppendValues 

func (th *Int8ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*Int8ColumnHandler) GetField 

func (th *Int8ColumnHandler) GetField() arrow.Field

func (*Int8ColumnHandler) GetVariable 

func (th *Int8ColumnHandler) GetVariable() interface{}

func (*Int8ColumnHandler) SetVariable 

func (th *Int8ColumnHandler) SetVariable(row int64)

type NullBinaryColumnHandler 

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

func NewNullBinaryColumnHandler 

func NewNullBinaryColumnHandler(name string, index int, batchSize int64) *NullBinaryColumnHandler

func (*NullBinaryColumnHandler) AppendValues 

func (th *NullBinaryColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullBinaryColumnHandler) GetField 

func (th *NullBinaryColumnHandler) GetField() arrow.Field

func (*NullBinaryColumnHandler) GetVariable 

func (th *NullBinaryColumnHandler) GetVariable() interface{}

func (*NullBinaryColumnHandler) SetVariable 

func (th *NullBinaryColumnHandler) SetVariable(row int64)

type NullBooleanColumnHandler 

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

func NewNullBooleanColumnHandler 

func NewNullBooleanColumnHandler(name string, index int, batchSize int64) *NullBooleanColumnHandler

func (*NullBooleanColumnHandler) AppendValues 

func (th *NullBooleanColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullBooleanColumnHandler) GetField 

func (th *NullBooleanColumnHandler) GetField() arrow.Field

func (*NullBooleanColumnHandler) GetVariable 

func (th *NullBooleanColumnHandler) GetVariable() interface{}

func (*NullBooleanColumnHandler) SetVariable 

func (th *NullBooleanColumnHandler) SetVariable(row int64)

type NullFloat32ColumnHandler 

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

func NewNullFloat32ColumnHandler 

func NewNullFloat32ColumnHandler(name string, index int, batchSize int64) *NullFloat32ColumnHandler

func (*NullFloat32ColumnHandler) AppendValues 

func (th *NullFloat32ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullFloat32ColumnHandler) GetField 

func (th *NullFloat32ColumnHandler) GetField() arrow.Field

func (*NullFloat32ColumnHandler) GetVariable 

func (th *NullFloat32ColumnHandler) GetVariable() interface{}

func (*NullFloat32ColumnHandler) SetVariable 

func (th *NullFloat32ColumnHandler) SetVariable(row int64)

type NullFloat64ColumnHandler 

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

func NewNullFloat64ColumnHandler 

func NewNullFloat64ColumnHandler(name string, index int, batchSize int64) *NullFloat64ColumnHandler

func (*NullFloat64ColumnHandler) AppendValues 

func (th *NullFloat64ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullFloat64ColumnHandler) GetField 

func (th *NullFloat64ColumnHandler) GetField() arrow.Field

func (*NullFloat64ColumnHandler) GetVariable 

func (th *NullFloat64ColumnHandler) GetVariable() interface{}

func (*NullFloat64ColumnHandler) SetVariable 

func (th *NullFloat64ColumnHandler) SetVariable(row int64)

type NullInt16ColumnHandler 

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

func NewNullInt16ColumnHandler 

func NewNullInt16ColumnHandler(name string, index int, batchSize int64) *NullInt16ColumnHandler

func (*NullInt16ColumnHandler) AppendValues 

func (th *NullInt16ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullInt16ColumnHandler) GetField 

func (th *NullInt16ColumnHandler) GetField() arrow.Field

func (*NullInt16ColumnHandler) GetVariable 

func (th *NullInt16ColumnHandler) GetVariable() interface{}

func (*NullInt16ColumnHandler) SetVariable 

func (th *NullInt16ColumnHandler) SetVariable(row int64)

type NullInt32ColumnHandler 

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

func NewNullInt32ColumnHandler 

func NewNullInt32ColumnHandler(name string, index int, batchSize int64) *NullInt32ColumnHandler

func (*NullInt32ColumnHandler) AppendValues 

func (th *NullInt32ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullInt32ColumnHandler) GetField 

func (th *NullInt32ColumnHandler) GetField() arrow.Field

func (*NullInt32ColumnHandler) GetVariable 

func (th *NullInt32ColumnHandler) GetVariable() interface{}

func (*NullInt32ColumnHandler) SetVariable 

func (th *NullInt32ColumnHandler) SetVariable(row int64)

type NullInt64ColumnHandler 

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

func NewNullInt64ColumnHandler 

func NewNullInt64ColumnHandler(name string, index int, batchSize int64) *NullInt64ColumnHandler

func (*NullInt64ColumnHandler) AppendValues 

func (th *NullInt64ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullInt64ColumnHandler) GetField 

func (th *NullInt64ColumnHandler) GetField() arrow.Field

func (*NullInt64ColumnHandler) GetVariable 

func (th *NullInt64ColumnHandler) GetVariable() interface{}

func (*NullInt64ColumnHandler) SetVariable 

func (th *NullInt64ColumnHandler) SetVariable(row int64)

type NullInt8ColumnHandler 

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

func NewNullInt8ColumnHandler 

func NewNullInt8ColumnHandler(name string, index int, batchSize int64) *NullInt8ColumnHandler

func (*NullInt8ColumnHandler) AppendValues 

func (th *NullInt8ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullInt8ColumnHandler) GetField 

func (th *NullInt8ColumnHandler) GetField() arrow.Field

func (*NullInt8ColumnHandler) GetVariable 

func (th *NullInt8ColumnHandler) GetVariable() interface{}

func (*NullInt8ColumnHandler) SetVariable 

func (th *NullInt8ColumnHandler) SetVariable(row int64)

type NullStringColumnHandler 

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

func NewNullStringColumnHandler 

func NewNullStringColumnHandler(name string, index int, batchSize int64) *NullStringColumnHandler

func (*NullStringColumnHandler) AppendValues 

func (th *NullStringColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullStringColumnHandler) GetField 

func (th *NullStringColumnHandler) GetField() arrow.Field

func (*NullStringColumnHandler) GetVariable 

func (th *NullStringColumnHandler) GetVariable() interface{}

func (*NullStringColumnHandler) SetVariable 

func (th *NullStringColumnHandler) SetVariable(row int64)

type NullTimestampColumnHandler 

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

func NewNullTimestampColumnHandler 

func NewNullTimestampColumnHandler(name string, index int, batchSize int64) *NullTimestampColumnHandler

func (*NullTimestampColumnHandler) AppendValues 

func (th *NullTimestampColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullTimestampColumnHandler) GetField 

func (th *NullTimestampColumnHandler) GetField() arrow.Field

func (*NullTimestampColumnHandler) GetVariable 

func (th *NullTimestampColumnHandler) GetVariable() interface{}

func (*NullTimestampColumnHandler) SetVariable 

func (th *NullTimestampColumnHandler) SetVariable(row int64)

type NullUint16ColumnHandler 

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

func NewNullUint16ColumnHandler 

func NewNullUint16ColumnHandler(name string, index int, batchSize int64) *NullUint16ColumnHandler

func (*NullUint16ColumnHandler) AppendValues 

func (th *NullUint16ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullUint16ColumnHandler) GetField 

func (th *NullUint16ColumnHandler) GetField() arrow.Field

func (*NullUint16ColumnHandler) GetVariable 

func (th *NullUint16ColumnHandler) GetVariable() interface{}

func (*NullUint16ColumnHandler) SetVariable 

func (th *NullUint16ColumnHandler) SetVariable(row int64)

type NullUint32ColumnHandler 

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

func NewNullUint32ColumnHandler 

func NewNullUint32ColumnHandler(name string, index int, batchSize int64) *NullUint32ColumnHandler

func (*NullUint32ColumnHandler) AppendValues 

func (th *NullUint32ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullUint32ColumnHandler) GetField 

func (th *NullUint32ColumnHandler) GetField() arrow.Field

func (*NullUint32ColumnHandler) GetVariable 

func (th *NullUint32ColumnHandler) GetVariable() interface{}

func (*NullUint32ColumnHandler) SetVariable 

func (th *NullUint32ColumnHandler) SetVariable(row int64)

type NullUint64ColumnHandler 

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

func NewNullUint64ColumnHandler 

func NewNullUint64ColumnHandler(name string, index int, batchSize int64) *NullUint64ColumnHandler

func (*NullUint64ColumnHandler) AppendValues 

func (th *NullUint64ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullUint64ColumnHandler) GetField 

func (th *NullUint64ColumnHandler) GetField() arrow.Field

func (*NullUint64ColumnHandler) GetVariable 

func (th *NullUint64ColumnHandler) GetVariable() interface{}

func (*NullUint64ColumnHandler) SetVariable 

func (th *NullUint64ColumnHandler) SetVariable(row int64)

type NullUint8ColumnHandler 

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

func NewNullUint8ColumnHandler 

func NewNullUint8ColumnHandler(name string, index int, batchSize int64) *NullUint8ColumnHandler

func (*NullUint8ColumnHandler) AppendValues 

func (th *NullUint8ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*NullUint8ColumnHandler) GetField 

func (th *NullUint8ColumnHandler) GetField() arrow.Field

func (*NullUint8ColumnHandler) GetVariable 

func (th *NullUint8ColumnHandler) GetVariable() interface{}

func (*NullUint8ColumnHandler) SetVariable 

func (th *NullUint8ColumnHandler) SetVariable(row int64)

type StringColumnHandler 

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

func NewStringColumnHandler 

func NewStringColumnHandler(name string, index int, batchSize int64) *StringColumnHandler

func (*StringColumnHandler) AppendValues 

func (th *StringColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*StringColumnHandler) GetField 

func (th *StringColumnHandler) GetField() arrow.Field

func (*StringColumnHandler) GetVariable 

func (th *StringColumnHandler) GetVariable() interface{}

func (*StringColumnHandler) SetVariable 

func (th *StringColumnHandler) SetVariable(row int64)

type Uint16ColumnHandler 

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

func NewUint16ColumnHandler 

func NewUint16ColumnHandler(name string, index int, batchSize int64) *Uint16ColumnHandler

func (*Uint16ColumnHandler) AppendValues 

func (th *Uint16ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*Uint16ColumnHandler) GetField 

func (th *Uint16ColumnHandler) GetField() arrow.Field

func (*Uint16ColumnHandler) GetVariable 

func (th *Uint16ColumnHandler) GetVariable() interface{}

func (*Uint16ColumnHandler) SetVariable 

func (th *Uint16ColumnHandler) SetVariable(row int64)

type Uint32ColumnHandler 

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

func NewUint32ColumnHandler 

func NewUint32ColumnHandler(name string, index int, batchSize int64) *Uint32ColumnHandler

func (*Uint32ColumnHandler) AppendValues 

func (th *Uint32ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*Uint32ColumnHandler) GetField 

func (th *Uint32ColumnHandler) GetField() arrow.Field

func (*Uint32ColumnHandler) GetVariable 

func (th *Uint32ColumnHandler) GetVariable() interface{}

func (*Uint32ColumnHandler) SetVariable 

func (th *Uint32ColumnHandler) SetVariable(row int64)

type Uint64ColumnHandler 

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

func NewUint64ColumnHandler 

func NewUint64ColumnHandler(name string, index int, batchSize int64) *Uint64ColumnHandler

func (*Uint64ColumnHandler) AppendValues 

func (th *Uint64ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*Uint64ColumnHandler) GetField 

func (th *Uint64ColumnHandler) GetField() arrow.Field

func (*Uint64ColumnHandler) GetVariable 

func (th *Uint64ColumnHandler) GetVariable() interface{}

func (*Uint64ColumnHandler) SetVariable 

func (th *Uint64ColumnHandler) SetVariable(row int64)

type Uint8ColumnHandler 

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

func NewUint8ColumnHandler 

func NewUint8ColumnHandler(name string, index int, batchSize int64) *Uint8ColumnHandler

func (*Uint8ColumnHandler) AppendValues 

func (th *Uint8ColumnHandler) AppendValues(builder *array.RecordBuilder, rows int64)

func (*Uint8ColumnHandler) GetField 

func (th *Uint8ColumnHandler) GetField() arrow.Field

func (*Uint8ColumnHandler) GetVariable 

func (th *Uint8ColumnHandler) GetVariable() interface{}

func (*Uint8ColumnHandler) SetVariable 

func (th *Uint8ColumnHandler) SetVariable(row int64)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.