column

package
v1.17.2 Latest Latest
Warning

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

 Go to latest Published: May 23, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	NULLDisplay = "ᴺᵁᴸᴸ"
	NULL        = "NULL"
	NULLSmall   = "null"
	NULLAlt     = "\\N"
)

Variables

View Source 
var (
	NESTED_TYPE_ERROR = fmt.Errorf("[parseNestedType]: failed to pass nested type")
)

Functions

func NewErrInvalidTupleElemCount 

func NewErrInvalidTupleElemCount(currentTuple interface{}, currentNumberOfElems, expectedNumberOfElems int) error

func WriteColumnToEncoder 

func WriteColumnToEncoder(encoder *ch_encoding.Encoder, c *CHColumn) error

Types

type ArrayColumnData 

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

ArrayColumnData's byte encoding A column of arrays is converted into a single long array in ReadFromTexts/ReadFromValues The length of each array are stored in offsetsRaw These values are known as "offset" To get back the values for each array, used the offsets to get the right slice from the single long array

func (*ArrayColumnData) Close 

func (a *ArrayColumnData) Close() error

func (*ArrayColumnData) GetString 

func (a *ArrayColumnData) GetString(row int) string

func (*ArrayColumnData) GetValue 

func (a *ArrayColumnData) GetValue(row int) interface{}

func (*ArrayColumnData) Len 

func (a *ArrayColumnData) Len() int

func (*ArrayColumnData) ReadFromDecoder 

func (a *ArrayColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*ArrayColumnData) ReadFromTexts 

func (a *ArrayColumnData) ReadFromTexts(texts []string) (int, error)

func (*ArrayColumnData) ReadFromValues 

func (a *ArrayColumnData) ReadFromValues(values []interface{}) (v int, err error)

func (*ArrayColumnData) WriteToEncoder 

func (a *ArrayColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*ArrayColumnData) Zero 

func (a *ArrayColumnData) Zero() interface{}

func (*ArrayColumnData) ZeroString 

func (a *ArrayColumnData) ZeroString() string

type BitMapColumnData 

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

BitMapColumnData Data representation is an uint64 array

func (*BitMapColumnData) Close 

func (b *BitMapColumnData) Close() error

func (*BitMapColumnData) GetString 

func (b *BitMapColumnData) GetString(row int) string

func (*BitMapColumnData) GetValue 

func (b *BitMapColumnData) GetValue(row int) interface{}

func (*BitMapColumnData) Len 

func (b *BitMapColumnData) Len() int

func (*BitMapColumnData) ReadFromDecoder 

func (b *BitMapColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

ReadFromDecoder populates data with value from decoder

func (*BitMapColumnData) ReadFromTexts 

func (b *BitMapColumnData) ReadFromTexts(texts []string) (int, error)

ReadFromTexts reads from text and assigns to bitmap data Bitmap is represented as array of uint64 E.g. [1, 3, 4]

func (*BitMapColumnData) ReadFromValues 

func (b *BitMapColumnData) ReadFromValues(values []interface{}) (int, error)

func (*BitMapColumnData) WriteToEncoder 

func (b *BitMapColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*BitMapColumnData) Zero 

func (b *BitMapColumnData) Zero() interface{}

func (*BitMapColumnData) ZeroString 

func (b *BitMapColumnData) ZeroString() string

type CHColumn 

type CHColumn struct {
	Name string
	Type CHColumnType
	Data CHColumnData

	GenerateColumn func(numRows int) CHColumnData // Acts like cache to fast generate complex data types of clickhouse
}

func ReadColumnFromDecoder 

func ReadColumnFromDecoder(decoder *ch_encoding.Decoder, numRows int) (*CHColumn, error)

func ReadColumnFromDecoderWithLocation 

func ReadColumnFromDecoderWithLocation(decoder *ch_encoding.Decoder, numRows int, location *time.Location) (*CHColumn, error)

func (*CHColumn) CHType 

func (c *CHColumn) CHType() string

func (*CHColumn) Close 

func (c *CHColumn) Close() error

func (*CHColumn) GetAllRows 

func (c *CHColumn) GetAllRows(result []interface{}) []interface{}

func (*CHColumn) GetAllRowsFmt 

func (c *CHColumn) GetAllRowsFmt(result []string) []string

func (*CHColumn) ScanType 

func (c *CHColumn) ScanType() reflect.Type

func (*CHColumn) StructureCopy 

func (c *CHColumn) StructureCopy(n int) *CHColumn

StructureCopy copies the CHColumn into newCHColumn with n rows

type CHColumnData 

type CHColumnData interface {
	// ReadFromDecoder fills the CHColumnData with input from decoder
	// Used when we receive data from clickhouse server
	ReadFromDecoder(decoder *ch_encoding.Decoder) error

	// WriteToEncoder write the data from CHColumnData to encoder
	// Used when we send data from clickhouse server
	WriteToEncoder(encoder *ch_encoding.Encoder) error

	// GetValue returns the value of CHColumnData at given row
	GetValue(row int) interface{}

	// GetString returns the string representation of value of CHColumnData at given row
	GetString(row int) string

	//Zero returns zero value of the CHColumnData
	Zero() interface{}

	//ZeroString return string representation of Zero of CHColumnData
	ZeroString() string

	// Len returns the number of rows of CHColumnData
	Len() int

	// Close recycles the CHColumnData, rendering it unusable
	Close() error

	// ReadFromTexts reads from slice of string into column. len of slice
	// must not exceed the len of column.
	// return total rows written and error if any
	ReadFromTexts(texts []string) (int, error)

	// ReadFromValues reads from slice of golang values into column. len of slice
	// must not exceed the len of column.
	// return total rows written and error if any
	ReadFromValues(values []interface{}) (int, error)
}

func MustMakeColumnData 

func MustMakeColumnData(t CHColumnType, numRows int) CHColumnData

MustMakeColumnData attempts to make column data with give type and row count. Panics if not possible

type CHColumnType 

type CHColumnType string
const (
	// base type
	INT8         CHColumnType = "Int8"
	INT16        CHColumnType = "Int16"
	INT32        CHColumnType = "Int32"
	INT64        CHColumnType = "Int64"
	INT128       CHColumnType = "Int128"
	INT256       CHColumnType = "Int256"
	UINT8        CHColumnType = "UInt8"
	UINT16       CHColumnType = "UInt16"
	UINT32       CHColumnType = "UInt32"
	UINT64       CHColumnType = "UInt64"
	UINT256      CHColumnType = "UInt256"
	FLOAT32      CHColumnType = "Float32"
	FLOAT64      CHColumnType = "Float64"
	STRING       CHColumnType = "String"
	UUID         CHColumnType = "UUID"
	DATE         CHColumnType = "Date"
	IPV4         CHColumnType = "IPv4"
	IPV6         CHColumnType = "IPv6"
	BITMAP64     CHColumnType = "BitMap64"
	NOTHING      CHColumnType = "Nothing"
	BOOLEAN      CHColumnType = "Boolean"
	POINT        CHColumnType = "Point"
	RING         CHColumnType = "Ring"
	POLYGON      CHColumnType = "Polygon"
	MULTIPOLYGON CHColumnType = "MultiPolygon"
	NESTED       CHColumnType = "Nested"

	// complex types with parameters
	NULLABLE       CHColumnType = "Nullable"
	ARRAY          CHColumnType = "Array"
	TUPLE          CHColumnType = "Tuple"
	MAP            CHColumnType = "Map"
	FIXEDSTRING    CHColumnType = "FixedString"
	ENUM8          CHColumnType = "Enum8"
	ENUM16         CHColumnType = "Enum16"
	DECIMAL        CHColumnType = "Decimal"
	DATETIME       CHColumnType = "DateTime"
	DATETIME64     CHColumnType = "DateTime64"
	LOWCARDINALITY CHColumnType = "LowCardinality"

	// alias types
	INT CHColumnType = "Int"

	// Aggregate functions
	AGGREGATEFUNCTION      CHColumnType = "AggregateFunction"
	SIMPLEAGGREATEFUNCTION CHColumnType = "SimpleAggregateFunction"
)

type DateColumnData 

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

func (*DateColumnData) Close 

func (d *DateColumnData) Close() error

func (*DateColumnData) GetString 

func (d *DateColumnData) GetString(row int) string

func (*DateColumnData) GetValue 

func (d *DateColumnData) GetValue(row int) interface{}

func (*DateColumnData) Len 

func (d *DateColumnData) Len() int

func (*DateColumnData) ReadFromDecoder 

func (d *DateColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*DateColumnData) ReadFromTexts 

func (d *DateColumnData) ReadFromTexts(texts []string) (int, error)

func (*DateColumnData) ReadFromValues 

func (d *DateColumnData) ReadFromValues(values []interface{}) (int, error)

func (*DateColumnData) WriteToEncoder 

func (d *DateColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*DateColumnData) Zero 

func (d *DateColumnData) Zero() interface{}

func (*DateColumnData) ZeroString 

func (d *DateColumnData) ZeroString() string

type DateTime64ColumnData 

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

func (*DateTime64ColumnData) Close 

func (d *DateTime64ColumnData) Close() error

func (*DateTime64ColumnData) GetString 

func (d *DateTime64ColumnData) GetString(row int) string

func (*DateTime64ColumnData) GetValue 

func (d *DateTime64ColumnData) GetValue(row int) interface{}

func (*DateTime64ColumnData) Len 

func (d *DateTime64ColumnData) Len() int

func (*DateTime64ColumnData) ReadFromDecoder 

func (d *DateTime64ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*DateTime64ColumnData) ReadFromTexts 

func (d *DateTime64ColumnData) ReadFromTexts(texts []string) (int, error)

func (*DateTime64ColumnData) ReadFromValues 

func (d *DateTime64ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*DateTime64ColumnData) WriteToEncoder 

func (d *DateTime64ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*DateTime64ColumnData) Zero 

func (d *DateTime64ColumnData) Zero() interface{}

func (*DateTime64ColumnData) ZeroString 

func (d *DateTime64ColumnData) ZeroString() string

type DateTimeColumnData 

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

func (*DateTimeColumnData) Close 

func (d *DateTimeColumnData) Close() error

func (*DateTimeColumnData) GetString 

func (d *DateTimeColumnData) GetString(row int) string

func (*DateTimeColumnData) GetValue 

func (d *DateTimeColumnData) GetValue(row int) interface{}

func (*DateTimeColumnData) Len 

func (d *DateTimeColumnData) Len() int

func (*DateTimeColumnData) ReadFromDecoder 

func (d *DateTimeColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*DateTimeColumnData) ReadFromTexts 

func (d *DateTimeColumnData) ReadFromTexts(texts []string) (int, error)

func (*DateTimeColumnData) ReadFromValues 

func (d *DateTimeColumnData) ReadFromValues(values []interface{}) (int, error)

func (*DateTimeColumnData) WriteToEncoder 

func (d *DateTimeColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*DateTimeColumnData) Zero 

func (d *DateTimeColumnData) Zero() interface{}

func (*DateTimeColumnData) ZeroString 

func (d *DateTimeColumnData) ZeroString() string

type DecimalColumnData 

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

DecimalColumnData represents Decimal(P, S) in Clickhouse. Decimals are fixed-point numbers that preserve precision for add, sub and mul operations.

For division least significant digits are discarded (not rounded). See https://clickhouse.tech/docs/en/sql-reference/data-types/decimal

func (*DecimalColumnData) Close 

func (d *DecimalColumnData) Close() error

func (*DecimalColumnData) GetString 

func (d *DecimalColumnData) GetString(row int) string

func (*DecimalColumnData) GetValue 

func (d *DecimalColumnData) GetValue(row int) interface{}

func (*DecimalColumnData) Len 

func (d *DecimalColumnData) Len() int

func (*DecimalColumnData) ReadFromDecoder 

func (d *DecimalColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*DecimalColumnData) ReadFromTexts 

func (d *DecimalColumnData) ReadFromTexts(texts []string) (int, error)

func (*DecimalColumnData) ReadFromValues 

func (d *DecimalColumnData) ReadFromValues(values []interface{}) (int, error)

func (*DecimalColumnData) WriteToEncoder 

func (d *DecimalColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*DecimalColumnData) Zero 

func (d *DecimalColumnData) Zero() interface{}

func (*DecimalColumnData) ZeroString 

func (d *DecimalColumnData) ZeroString() string

type Enum16ColumnData 

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

func (*Enum16ColumnData) Close 

func (e *Enum16ColumnData) Close() error

func (*Enum16ColumnData) GetString 

func (e *Enum16ColumnData) GetString(row int) string

func (*Enum16ColumnData) GetValue 

func (e *Enum16ColumnData) GetValue(row int) interface{}

func (*Enum16ColumnData) Len 

func (e *Enum16ColumnData) Len() int

func (*Enum16ColumnData) ReadFromDecoder 

func (e *Enum16ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*Enum16ColumnData) ReadFromTexts 

func (e *Enum16ColumnData) ReadFromTexts(texts []string) (int, error)

func (*Enum16ColumnData) ReadFromValues 

func (e *Enum16ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*Enum16ColumnData) WriteToEncoder 

func (e *Enum16ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*Enum16ColumnData) Zero 

func (e *Enum16ColumnData) Zero() interface{}

func (*Enum16ColumnData) ZeroString 

func (e *Enum16ColumnData) ZeroString() string

type Enum8ColumnData 

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

func (*Enum8ColumnData) Close 

func (e *Enum8ColumnData) Close() error

func (*Enum8ColumnData) GetString 

func (e *Enum8ColumnData) GetString(row int) string

func (*Enum8ColumnData) GetValue 

func (e *Enum8ColumnData) GetValue(row int) interface{}

func (*Enum8ColumnData) Len 

func (e *Enum8ColumnData) Len() int

func (*Enum8ColumnData) ReadFromDecoder 

func (e *Enum8ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*Enum8ColumnData) ReadFromTexts 

func (e *Enum8ColumnData) ReadFromTexts(texts []string) (int, error)

func (*Enum8ColumnData) ReadFromValues 

func (e *Enum8ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*Enum8ColumnData) WriteToEncoder 

func (e *Enum8ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*Enum8ColumnData) Zero 

func (e *Enum8ColumnData) Zero() interface{}

func (*Enum8ColumnData) ZeroString 

func (e *Enum8ColumnData) ZeroString() string

type ErrInvalidColumnType 

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

ErrInvalidColumnType is a connection err Returning this err will cause upstream sql driver to return ErrBadConn, causing the connection to be discarded.

func NewErrInvalidColumnType 

func NewErrInvalidColumnType(current, expected interface{}) *ErrInvalidColumnType

func NewErrInvalidColumnTypeCustomText 

func NewErrInvalidColumnTypeCustomText(text string) *ErrInvalidColumnType

func (ErrInvalidColumnType) Error 

func (e ErrInvalidColumnType) Error() string

func (ErrInvalidColumnType) Is 

func (e ErrInvalidColumnType) Is(target error) bool

Is returns true if target is of ErrInvalidColumnType

type FixedStringColumnData 

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

func (*FixedStringColumnData) Close 

func (f *FixedStringColumnData) Close() error

func (*FixedStringColumnData) GetString 

func (f *FixedStringColumnData) GetString(row int) string

func (*FixedStringColumnData) GetValue 

func (f *FixedStringColumnData) GetValue(row int) interface{}

func (*FixedStringColumnData) Len 

func (f *FixedStringColumnData) Len() int

func (*FixedStringColumnData) ReadFromDecoder 

func (f *FixedStringColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*FixedStringColumnData) ReadFromTexts 

func (f *FixedStringColumnData) ReadFromTexts(texts []string) (int, error)

func (*FixedStringColumnData) ReadFromValues 

func (f *FixedStringColumnData) ReadFromValues(values []interface{}) (int, error)

func (*FixedStringColumnData) WriteToEncoder 

func (f *FixedStringColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*FixedStringColumnData) Zero 

func (f *FixedStringColumnData) Zero() interface{}

func (*FixedStringColumnData) ZeroString 

func (f *FixedStringColumnData) ZeroString() string

type Float32ColumnData 

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

Float32ColumnData handles float32 column types Float32ColumnData doesn't guarantee precision of values larger then MaxFloat32

func (*Float32ColumnData) Close 

func (f *Float32ColumnData) Close() error

func (*Float32ColumnData) GetString 

func (f *Float32ColumnData) GetString(row int) string

func (*Float32ColumnData) GetValue 

func (f *Float32ColumnData) GetValue(row int) interface{}

func (*Float32ColumnData) Len 

func (f *Float32ColumnData) Len() int

func (*Float32ColumnData) ReadFromDecoder 

func (f *Float32ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*Float32ColumnData) ReadFromTexts 

func (f *Float32ColumnData) ReadFromTexts(texts []string) (int, error)

func (*Float32ColumnData) ReadFromValues 

func (f *Float32ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*Float32ColumnData) WriteToEncoder 

func (f *Float32ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*Float32ColumnData) Zero 

func (f *Float32ColumnData) Zero() interface{}

func (*Float32ColumnData) ZeroString 

func (f *Float32ColumnData) ZeroString() string

type Float64ColumnData 

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

func (*Float64ColumnData) Close 

func (f *Float64ColumnData) Close() error

func (*Float64ColumnData) GetString 

func (f *Float64ColumnData) GetString(row int) string

func (*Float64ColumnData) GetValue 

func (f *Float64ColumnData) GetValue(row int) interface{}

func (*Float64ColumnData) Len 

func (f *Float64ColumnData) Len() int

func (*Float64ColumnData) ReadFromDecoder 

func (f *Float64ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*Float64ColumnData) ReadFromTexts 

func (f *Float64ColumnData) ReadFromTexts(texts []string) (int, error)

func (*Float64ColumnData) ReadFromValues 

func (f *Float64ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*Float64ColumnData) WriteToEncoder 

func (f *Float64ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*Float64ColumnData) Zero 

func (f *Float64ColumnData) Zero() interface{}

func (*Float64ColumnData) ZeroString 

func (f *Float64ColumnData) ZeroString() string

type GenerateColumnData 

type GenerateColumnData func(numRows int) CHColumnData

GenerateColumnData generates CH column based for numRows all rows are initialized to respective zero value

func GenerateColumnDataFactory 

func GenerateColumnDataFactory(t CHColumnType) (GenerateColumnData, error)

func GenerateColumnDataFactoryWithLocation 

func GenerateColumnDataFactoryWithLocation(t CHColumnType, location *time.Location) (GenerateColumnData, error)

func MustGenerateColumnDataFactory 

func MustGenerateColumnDataFactory(t CHColumnType) GenerateColumnData

type IPv4ColumnData 

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

func (*IPv4ColumnData) Close 

func (i *IPv4ColumnData) Close() error

func (*IPv4ColumnData) GetString 

func (i *IPv4ColumnData) GetString(row int) string

func (*IPv4ColumnData) GetValue 

func (i *IPv4ColumnData) GetValue(row int) interface{}

func (*IPv4ColumnData) Len 

func (i *IPv4ColumnData) Len() int

func (*IPv4ColumnData) ReadFromDecoder 

func (i *IPv4ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*IPv4ColumnData) ReadFromTexts 

func (i *IPv4ColumnData) ReadFromTexts(texts []string) (int, error)

func (*IPv4ColumnData) ReadFromValues 

func (i *IPv4ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*IPv4ColumnData) WriteToEncoder 

func (i *IPv4ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*IPv4ColumnData) Zero 

func (i *IPv4ColumnData) Zero() interface{}

func (*IPv4ColumnData) ZeroString 

func (i *IPv4ColumnData) ZeroString() string

type IPv6ColumnData 

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

func (*IPv6ColumnData) Close 

func (i *IPv6ColumnData) Close() error

func (*IPv6ColumnData) GetString 

func (i *IPv6ColumnData) GetString(row int) string

func (*IPv6ColumnData) GetValue 

func (i *IPv6ColumnData) GetValue(row int) interface{}

func (*IPv6ColumnData) Len 

func (i *IPv6ColumnData) Len() int

func (*IPv6ColumnData) ReadFromDecoder 

func (i *IPv6ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*IPv6ColumnData) ReadFromTexts 

func (i *IPv6ColumnData) ReadFromTexts(texts []string) (int, error)

func (*IPv6ColumnData) ReadFromValues 

func (i *IPv6ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*IPv6ColumnData) WriteToEncoder 

func (i *IPv6ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*IPv6ColumnData) Zero 

func (i *IPv6ColumnData) Zero() interface{}

func (*IPv6ColumnData) ZeroString 

func (i *IPv6ColumnData) ZeroString() string

type Int16ColumnData 

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

func (*Int16ColumnData) Close 

func (i *Int16ColumnData) Close() error

func (*Int16ColumnData) GetString 

func (i *Int16ColumnData) GetString(row int) string

func (*Int16ColumnData) GetValue 

func (i *Int16ColumnData) GetValue(row int) interface{}

func (*Int16ColumnData) Len 

func (i *Int16ColumnData) Len() int

func (*Int16ColumnData) ReadFromDecoder 

func (i *Int16ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*Int16ColumnData) ReadFromTexts 

func (i *Int16ColumnData) ReadFromTexts(texts []string) (int, error)

func (*Int16ColumnData) ReadFromValues 

func (i *Int16ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*Int16ColumnData) WriteToEncoder 

func (i *Int16ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*Int16ColumnData) Zero 

func (i *Int16ColumnData) Zero() interface{}

func (*Int16ColumnData) ZeroString 

func (i *Int16ColumnData) ZeroString() string

type Int32ColumnData 

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

func (*Int32ColumnData) Close 

func (i *Int32ColumnData) Close() error

func (*Int32ColumnData) GetString 

func (i *Int32ColumnData) GetString(row int) string

func (*Int32ColumnData) GetValue 

func (i *Int32ColumnData) GetValue(row int) interface{}

func (*Int32ColumnData) Len 

func (i *Int32ColumnData) Len() int

func (*Int32ColumnData) ReadFromDecoder 

func (i *Int32ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*Int32ColumnData) ReadFromTexts 

func (i *Int32ColumnData) ReadFromTexts(texts []string) (int, error)

func (*Int32ColumnData) ReadFromValues 

func (i *Int32ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*Int32ColumnData) WriteToEncoder 

func (i *Int32ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*Int32ColumnData) Zero 

func (i *Int32ColumnData) Zero() interface{}

func (*Int32ColumnData) ZeroString 

func (i *Int32ColumnData) ZeroString() string

type Int64ColumnData 

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

func (*Int64ColumnData) Close 

func (i *Int64ColumnData) Close() error

func (*Int64ColumnData) GetString 

func (i *Int64ColumnData) GetString(row int) string

func (*Int64ColumnData) GetValue 

func (i *Int64ColumnData) GetValue(row int) interface{}

func (*Int64ColumnData) Len 

func (i *Int64ColumnData) Len() int

func (*Int64ColumnData) ReadFromDecoder 

func (i *Int64ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*Int64ColumnData) ReadFromTexts 

func (i *Int64ColumnData) ReadFromTexts(texts []string) (int, error)

func (*Int64ColumnData) ReadFromValues 

func (i *Int64ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*Int64ColumnData) WriteToEncoder 

func (i *Int64ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*Int64ColumnData) Zero 

func (i *Int64ColumnData) Zero() interface{}

func (*Int64ColumnData) ZeroString 

func (i *Int64ColumnData) ZeroString() string

type Int8ColumnData 

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

func (*Int8ColumnData) Close 

func (i *Int8ColumnData) Close() error

func (*Int8ColumnData) GetString 

func (i *Int8ColumnData) GetString(row int) string

func (*Int8ColumnData) GetValue 

func (i *Int8ColumnData) GetValue(row int) interface{}

func (*Int8ColumnData) Len 

func (i *Int8ColumnData) Len() int

func (*Int8ColumnData) ReadFromDecoder 

func (i *Int8ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*Int8ColumnData) ReadFromTexts 

func (i *Int8ColumnData) ReadFromTexts(texts []string) (int, error)

func (*Int8ColumnData) ReadFromValues 

func (i *Int8ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*Int8ColumnData) WriteToEncoder 

func (i *Int8ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*Int8ColumnData) Zero 

func (i *Int8ColumnData) Zero() interface{}

func (*Int8ColumnData) ZeroString 

func (i *Int8ColumnData) ZeroString() string

type LowCardinalityColumnData 

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

LowCardinality What is low cardinality: https://altinity.com/blog/2019/3/27/low-cardinality Example: 3 kinds of strings a, b, c 1. Send a, b, c (Can be any order) 2. Send 3 indexes - uint format, e.g. 4, 5, 7 3. Result dictionary - {a: 4, b: 5, c: 7} 4. Send rows - e.g. 4, 5, 5, 5, 7 (equals to a, b, b, b, c) 5. Retrieve row at 5 - Search dictionary to find string -> b

func (*LowCardinalityColumnData) Close 

func (l *LowCardinalityColumnData) Close() error

func (*LowCardinalityColumnData) GetString 

func (l *LowCardinalityColumnData) GetString(row int) string

func (*LowCardinalityColumnData) GetValue 

func (l *LowCardinalityColumnData) GetValue(row int) interface{}

func (*LowCardinalityColumnData) Len 

func (l *LowCardinalityColumnData) Len() int

func (*LowCardinalityColumnData) ReadFromDecoder 

func (l *LowCardinalityColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*LowCardinalityColumnData) ReadFromTexts 

func (l *LowCardinalityColumnData) ReadFromTexts(texts []string) (int, error)

func (*LowCardinalityColumnData) ReadFromValues 

func (l *LowCardinalityColumnData) ReadFromValues(values []interface{}) (int, error)

func (*LowCardinalityColumnData) WriteToEncoder 

func (l *LowCardinalityColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*LowCardinalityColumnData) Zero 

func (l *LowCardinalityColumnData) Zero() interface{}

func (*LowCardinalityColumnData) ZeroString 

func (l *LowCardinalityColumnData) ZeroString() string

type MapColumnData 

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

MapColumnData's data representation Map is represented with 2 arrays of same length One array contains the keys, the other contains the values Values of keys can't be another map For example: For the map below {1 : a, 2: b} {3: c, 4: d, 5: e} These are the arrays of keys [1 2] [3 4 5] These are the arrays of values [a b] [c d e] The key arrays are combined, same with the values arrays Hence offsets are also stored to know the boundary index of each map for reconstruction later The offsets for the above example are 2 and 5

To retrieve first map: 1. offset = 2 2. offset of previous = 0 3. get from 0 to 2 from of the keys array and values array 4. reconstruct map

func (*MapColumnData) Close 

func (m *MapColumnData) Close() error

func (*MapColumnData) GetString 

func (m *MapColumnData) GetString(row int) string

func (*MapColumnData) GetValue 

func (m *MapColumnData) GetValue(row int) interface{}

func (*MapColumnData) Len 

func (m *MapColumnData) Len() int

func (*MapColumnData) ReadFromDecoder 

func (m *MapColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*MapColumnData) ReadFromTexts 

func (m *MapColumnData) ReadFromTexts(texts []string) (int, error)

func (*MapColumnData) ReadFromValues 

func (m *MapColumnData) ReadFromValues(values []interface{}) (numRead int, err error)

func (*MapColumnData) WriteToEncoder 

func (m *MapColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*MapColumnData) Zero 

func (m *MapColumnData) Zero() interface{}

func (*MapColumnData) ZeroString 

func (m *MapColumnData) ZeroString() string

type NothingColumnData 

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

func (*NothingColumnData) Close 

func (n *NothingColumnData) Close() error

func (*NothingColumnData) GetString 

func (n *NothingColumnData) GetString(row int) string

func (*NothingColumnData) GetValue 

func (n *NothingColumnData) GetValue(row int) interface{}

func (*NothingColumnData) Len 

func (n *NothingColumnData) Len() int

func (*NothingColumnData) ReadFromDecoder 

func (n *NothingColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*NothingColumnData) ReadFromTexts 

func (n *NothingColumnData) ReadFromTexts(texts []string) (int, error)

func (*NothingColumnData) ReadFromValues 

func (n *NothingColumnData) ReadFromValues(values []interface{}) (int, error)

func (*NothingColumnData) WriteToEncoder 

func (n *NothingColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*NothingColumnData) Zero 

func (n *NothingColumnData) Zero() interface{}

func (*NothingColumnData) ZeroString 

func (n *NothingColumnData) ZeroString() string

type NullableColumnData 

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

func (*NullableColumnData) Close 

func (n *NullableColumnData) Close() error

func (*NullableColumnData) GetInnerColumnData 

func (n *NullableColumnData) GetInnerColumnData() CHColumnData

func (*NullableColumnData) GetString 

func (n *NullableColumnData) GetString(row int) string

func (*NullableColumnData) GetValue 

func (n *NullableColumnData) GetValue(row int) interface{}

func (*NullableColumnData) Len 

func (n *NullableColumnData) Len() int

func (*NullableColumnData) ReadFromDecoder 

func (n *NullableColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*NullableColumnData) ReadFromTexts 

func (n *NullableColumnData) ReadFromTexts(texts []string) (int, error)

func (*NullableColumnData) ReadFromValues 

func (n *NullableColumnData) ReadFromValues(values []interface{}) (int, error)

func (*NullableColumnData) WriteToEncoder 

func (n *NullableColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*NullableColumnData) Zero 

func (n *NullableColumnData) Zero() interface{}

func (*NullableColumnData) ZeroString 

func (n *NullableColumnData) ZeroString() string

type StringColumnData 

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

func (*StringColumnData) Close 

func (s *StringColumnData) Close() error

func (*StringColumnData) GetString 

func (s *StringColumnData) GetString(row int) string

func (*StringColumnData) GetValue 

func (s *StringColumnData) GetValue(row int) interface{}

func (*StringColumnData) Len 

func (s *StringColumnData) Len() int

func (*StringColumnData) ReadFromDecoder 

func (s *StringColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*StringColumnData) ReadFromTexts 

func (s *StringColumnData) ReadFromTexts(texts []string) (int, error)

func (*StringColumnData) ReadFromValues 

func (s *StringColumnData) ReadFromValues(values []interface{}) (int, error)

func (*StringColumnData) WriteToEncoder 

func (s *StringColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*StringColumnData) Zero 

func (s *StringColumnData) Zero() interface{}

func (*StringColumnData) ZeroString 

func (s *StringColumnData) ZeroString() string

type TupleColumnData 

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

func (*TupleColumnData) Close 

func (t *TupleColumnData) Close() error

func (*TupleColumnData) GetString 

func (t *TupleColumnData) GetString(row int) string

func (*TupleColumnData) GetValue 

func (t *TupleColumnData) GetValue(row int) interface{}

func (*TupleColumnData) Len 

func (t *TupleColumnData) Len() int

func (*TupleColumnData) ReadFromDecoder 

func (t *TupleColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*TupleColumnData) ReadFromTexts 

func (t *TupleColumnData) ReadFromTexts(texts []string) (int, error)

func (*TupleColumnData) ReadFromValues 

func (t *TupleColumnData) ReadFromValues(values []interface{}) (int, error)

func (*TupleColumnData) WriteToEncoder 

func (t *TupleColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*TupleColumnData) Zero 

func (t *TupleColumnData) Zero() interface{}

func (*TupleColumnData) ZeroString 

func (t *TupleColumnData) ZeroString() string

type UInt16ColumnData 

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

func (*UInt16ColumnData) Close 

func (u *UInt16ColumnData) Close() error

func (*UInt16ColumnData) GetString 

func (u *UInt16ColumnData) GetString(row int) string

func (*UInt16ColumnData) GetValue 

func (u *UInt16ColumnData) GetValue(row int) interface{}

func (*UInt16ColumnData) Len 

func (u *UInt16ColumnData) Len() int

func (*UInt16ColumnData) ReadFromDecoder 

func (u *UInt16ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*UInt16ColumnData) ReadFromTexts 

func (u *UInt16ColumnData) ReadFromTexts(texts []string) (int, error)

func (*UInt16ColumnData) ReadFromValues 

func (i *UInt16ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*UInt16ColumnData) WriteToEncoder 

func (u *UInt16ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*UInt16ColumnData) Zero 

func (u *UInt16ColumnData) Zero() interface{}

func (*UInt16ColumnData) ZeroString 

func (u *UInt16ColumnData) ZeroString() string

type UInt32ColumnData 

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

func (*UInt32ColumnData) Close 

func (u *UInt32ColumnData) Close() error

func (*UInt32ColumnData) GetString 

func (u *UInt32ColumnData) GetString(row int) string

func (*UInt32ColumnData) GetValue 

func (u *UInt32ColumnData) GetValue(row int) interface{}

func (*UInt32ColumnData) Len 

func (u *UInt32ColumnData) Len() int

func (*UInt32ColumnData) ReadFromDecoder 

func (u *UInt32ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*UInt32ColumnData) ReadFromTexts 

func (u *UInt32ColumnData) ReadFromTexts(texts []string) (int, error)

func (*UInt32ColumnData) ReadFromValues 

func (u *UInt32ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*UInt32ColumnData) WriteToEncoder 

func (u *UInt32ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*UInt32ColumnData) Zero 

func (u *UInt32ColumnData) Zero() interface{}

func (*UInt32ColumnData) ZeroString 

func (u *UInt32ColumnData) ZeroString() string

type UInt64ColumnData 

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

func (*UInt64ColumnData) Close 

func (u *UInt64ColumnData) Close() error

func (*UInt64ColumnData) GetString 

func (u *UInt64ColumnData) GetString(row int) string

func (*UInt64ColumnData) GetValue 

func (u *UInt64ColumnData) GetValue(row int) interface{}

func (*UInt64ColumnData) Len 

func (u *UInt64ColumnData) Len() int

func (*UInt64ColumnData) ReadFromDecoder 

func (u *UInt64ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*UInt64ColumnData) ReadFromTexts 

func (u *UInt64ColumnData) ReadFromTexts(texts []string) (int, error)

func (*UInt64ColumnData) ReadFromValues 

func (u *UInt64ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*UInt64ColumnData) WriteToEncoder 

func (u *UInt64ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*UInt64ColumnData) Zero 

func (u *UInt64ColumnData) Zero() interface{}

func (*UInt64ColumnData) ZeroString 

func (u *UInt64ColumnData) ZeroString() string

type UInt8ColumnData 

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

func (*UInt8ColumnData) Close 

func (u *UInt8ColumnData) Close() error

func (*UInt8ColumnData) GetString 

func (u *UInt8ColumnData) GetString(row int) string

func (*UInt8ColumnData) GetValue 

func (u *UInt8ColumnData) GetValue(row int) interface{}

func (*UInt8ColumnData) Len 

func (u *UInt8ColumnData) Len() int

func (*UInt8ColumnData) ReadFromDecoder 

func (u *UInt8ColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*UInt8ColumnData) ReadFromTexts 

func (u *UInt8ColumnData) ReadFromTexts(texts []string) (int, error)

func (*UInt8ColumnData) ReadFromValues 

func (u *UInt8ColumnData) ReadFromValues(values []interface{}) (int, error)

func (*UInt8ColumnData) WriteToEncoder 

func (u *UInt8ColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*UInt8ColumnData) Zero 

func (u *UInt8ColumnData) Zero() interface{}

func (*UInt8ColumnData) ZeroString 

func (u *UInt8ColumnData) ZeroString() string

type UUIDColumnData 

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

func (*UUIDColumnData) Close 

func (u *UUIDColumnData) Close() error

func (*UUIDColumnData) GetString 

func (u *UUIDColumnData) GetString(row int) string

func (*UUIDColumnData) GetValue 

func (u *UUIDColumnData) GetValue(row int) interface{}

func (*UUIDColumnData) Len 

func (u *UUIDColumnData) Len() int

func (*UUIDColumnData) ReadFromDecoder 

func (u *UUIDColumnData) ReadFromDecoder(decoder *ch_encoding.Decoder) error

func (*UUIDColumnData) ReadFromTexts 

func (u *UUIDColumnData) ReadFromTexts(texts []string) (int, error)

func (*UUIDColumnData) ReadFromValues 

func (u *UUIDColumnData) ReadFromValues(values []interface{}) (int, error)

func (*UUIDColumnData) WriteToEncoder 

func (u *UUIDColumnData) WriteToEncoder(encoder *ch_encoding.Encoder) error

func (*UUIDColumnData) Zero 

func (u *UUIDColumnData) Zero() interface{}

func (*UUIDColumnData) ZeroString 

func (u *UUIDColumnData) ZeroString() string

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.