column

package
v2.6.7 Latest Latest
Warning

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

Go to latest
Published: Mar 3, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IPv6ToBytes

func IPv6ToBytes(ip net.IP) [16]byte

Types

type Array

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

func (*Array) Append

func (col *Array) Append(v interface{}) (nulls []uint8, err error)

func (*Array) AppendRow

func (col *Array) AppendRow(v interface{}) error

func (*Array) Base

func (col *Array) Base() Interface

func (*Array) Decode

func (col *Array) Decode(reader *proto.Reader, rows int) error

func (*Array) Encode

func (col *Array) Encode(buffer *proto.Buffer)

func (*Array) Name

func (col *Array) Name() string

func (*Array) ReadStatePrefix

func (col *Array) ReadStatePrefix(reader *proto.Reader) error

func (*Array) Reset

func (col *Array) Reset()

func (*Array) Row

func (col *Array) Row(i int, ptr bool) interface{}

func (*Array) Rows

func (col *Array) Rows() int

func (*Array) ScanRow

func (col *Array) ScanRow(dest interface{}, row int) error

func (*Array) ScanType

func (col *Array) ScanType() reflect.Type

func (*Array) Type

func (col *Array) Type() Type

func (*Array) WriteStatePrefix

func (col *Array) WriteStatePrefix(buffer *proto.Buffer) error

type BigInt

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

func (*BigInt) Append

func (col *BigInt) Append(v interface{}) (nulls []uint8, err error)

func (*BigInt) AppendRow

func (col *BigInt) AppendRow(v interface{}) error

func (*BigInt) Decode

func (col *BigInt) Decode(reader *proto.Reader, rows int) error

func (*BigInt) Encode

func (col *BigInt) Encode(buffer *proto.Buffer)

func (*BigInt) Name

func (col *BigInt) Name() string

func (*BigInt) Reset

func (col *BigInt) Reset()

func (*BigInt) Row

func (col *BigInt) Row(i int, ptr bool) interface{}

func (*BigInt) Rows

func (col *BigInt) Rows() int

func (*BigInt) ScanRow

func (col *BigInt) ScanRow(dest interface{}, row int) error

func (*BigInt) ScanType

func (col *BigInt) ScanType() reflect.Type

func (*BigInt) Type

func (col *BigInt) Type() Type

type Bool

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

func (*Bool) Append

func (col *Bool) Append(v interface{}) (nulls []uint8, err error)

func (*Bool) AppendRow

func (col *Bool) AppendRow(v interface{}) error

func (*Bool) Decode

func (col *Bool) Decode(reader *proto.Reader, rows int) error

func (*Bool) Encode

func (col *Bool) Encode(buffer *proto.Buffer)

func (*Bool) Name

func (col *Bool) Name() string

func (*Bool) Reset

func (col *Bool) Reset()

func (*Bool) Row

func (col *Bool) Row(i int, ptr bool) interface{}

func (*Bool) Rows

func (col *Bool) Rows() int

func (*Bool) ScanRow

func (col *Bool) ScanRow(dest interface{}, row int) error

func (*Bool) ScanType

func (col *Bool) ScanType() reflect.Type

func (*Bool) Type

func (col *Bool) Type() Type

type ColumnConverterError

type ColumnConverterError struct {
	Op       string
	Hint     string
	From, To string
}

func (*ColumnConverterError) Error

func (e *ColumnConverterError) Error() string

type CustomSerialization

type CustomSerialization interface {
	ReadStatePrefix(*proto.Reader) error
	WriteStatePrefix(*proto.Buffer) error
}

type Date

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

func (*Date) Append

func (col *Date) Append(v interface{}) (nulls []uint8, err error)

func (*Date) AppendRow

func (col *Date) AppendRow(v interface{}) error

func (*Date) Decode

func (col *Date) Decode(reader *proto.Reader, rows int) error

func (*Date) Encode

func (col *Date) Encode(buffer *proto.Buffer)

func (*Date) Name

func (col *Date) Name() string

func (*Date) Reset

func (col *Date) Reset()

func (*Date) Row

func (col *Date) Row(i int, ptr bool) interface{}

func (*Date) Rows

func (col *Date) Rows() int

func (*Date) ScanRow

func (col *Date) ScanRow(dest interface{}, row int) error

func (*Date) ScanType

func (col *Date) ScanType() reflect.Type

func (*Date) Type

func (col *Date) Type() Type

type Date32

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

func (*Date32) Append

func (col *Date32) Append(v interface{}) (nulls []uint8, err error)

func (*Date32) AppendRow

func (col *Date32) AppendRow(v interface{}) error

func (*Date32) Decode

func (col *Date32) Decode(reader *proto.Reader, rows int) error

func (*Date32) Encode

func (col *Date32) Encode(buffer *proto.Buffer)

func (*Date32) Name

func (col *Date32) Name() string

func (*Date32) Reset

func (col *Date32) Reset()

func (*Date32) Row

func (col *Date32) Row(i int, ptr bool) interface{}

func (*Date32) Rows

func (col *Date32) Rows() int

func (*Date32) ScanRow

func (col *Date32) ScanRow(dest interface{}, row int) error

func (*Date32) ScanType

func (col *Date32) ScanType() reflect.Type

func (*Date32) Type

func (col *Date32) Type() Type

type DateOverflowError

type DateOverflowError struct {
	Min, Max time.Time
	Value    time.Time
	Format   string
}

func (*DateOverflowError) Error

func (e *DateOverflowError) Error() string

type DateTime

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

func (*DateTime) Append

func (col *DateTime) Append(v interface{}) (nulls []uint8, err error)

func (*DateTime) AppendRow

func (col *DateTime) AppendRow(v interface{}) error

func (*DateTime) Decode

func (col *DateTime) Decode(reader *proto.Reader, rows int) error

func (*DateTime) Encode

func (col *DateTime) Encode(buffer *proto.Buffer)

func (*DateTime) Name

func (col *DateTime) Name() string

func (*DateTime) Reset

func (col *DateTime) Reset()

func (*DateTime) Row

func (col *DateTime) Row(i int, ptr bool) interface{}

func (*DateTime) Rows

func (col *DateTime) Rows() int

func (*DateTime) ScanRow

func (col *DateTime) ScanRow(dest interface{}, row int) error

func (*DateTime) ScanType

func (col *DateTime) ScanType() reflect.Type

func (*DateTime) Type

func (col *DateTime) Type() Type

type DateTime64

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

func (*DateTime64) Append

func (col *DateTime64) Append(v interface{}) (nulls []uint8, err error)

func (*DateTime64) AppendRow

func (col *DateTime64) AppendRow(v interface{}) error

func (*DateTime64) Decode

func (col *DateTime64) Decode(reader *proto.Reader, rows int) error

func (*DateTime64) Encode

func (col *DateTime64) Encode(buffer *proto.Buffer)

func (*DateTime64) Name

func (col *DateTime64) Name() string

func (*DateTime64) Reset

func (col *DateTime64) Reset()

func (*DateTime64) Row

func (col *DateTime64) Row(i int, ptr bool) interface{}

func (*DateTime64) Rows

func (col *DateTime64) Rows() int

func (*DateTime64) ScanRow

func (col *DateTime64) ScanRow(dest interface{}, row int) error

func (*DateTime64) ScanType

func (col *DateTime64) ScanType() reflect.Type

func (*DateTime64) Type

func (col *DateTime64) Type() Type

type Decimal

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

func (*Decimal) Append

func (col *Decimal) Append(v interface{}) (nulls []uint8, err error)

func (*Decimal) AppendRow

func (col *Decimal) AppendRow(v interface{}) error

func (*Decimal) Decode

func (col *Decimal) Decode(reader *proto.Reader, rows int) error

func (*Decimal) Encode

func (col *Decimal) Encode(buffer *proto.Buffer)

func (*Decimal) Name

func (col *Decimal) Name() string

func (*Decimal) Precision

func (col *Decimal) Precision() int64

func (*Decimal) Reset

func (col *Decimal) Reset()

func (*Decimal) Row

func (col *Decimal) Row(i int, ptr bool) interface{}

func (*Decimal) Rows

func (col *Decimal) Rows() int

func (*Decimal) Scale

func (col *Decimal) Scale() int64

func (*Decimal) ScanRow

func (col *Decimal) ScanRow(dest interface{}, row int) error

func (*Decimal) ScanType

func (col *Decimal) ScanType() reflect.Type

func (*Decimal) Type

func (col *Decimal) Type() Type

type Enum16

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

func (*Enum16) Append

func (col *Enum16) Append(v interface{}) (nulls []uint8, err error)

func (*Enum16) AppendRow

func (col *Enum16) AppendRow(elem interface{}) error

func (*Enum16) Decode

func (col *Enum16) Decode(reader *proto.Reader, rows int) error

func (*Enum16) Encode

func (col *Enum16) Encode(buffer *proto.Buffer)

func (*Enum16) Name

func (col *Enum16) Name() string

func (*Enum16) Reset

func (col *Enum16) Reset()

func (*Enum16) Row

func (col *Enum16) Row(i int, ptr bool) interface{}

func (*Enum16) Rows

func (col *Enum16) Rows() int

func (*Enum16) ScanRow

func (col *Enum16) ScanRow(dest interface{}, row int) error

func (*Enum16) ScanType

func (col *Enum16) ScanType() reflect.Type

func (*Enum16) Type

func (col *Enum16) Type() Type

type Enum8

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

func (*Enum8) Append

func (col *Enum8) Append(v interface{}) (nulls []uint8, err error)

func (*Enum8) AppendRow

func (col *Enum8) AppendRow(elem interface{}) error

func (*Enum8) Decode

func (col *Enum8) Decode(reader *proto.Reader, rows int) error

func (*Enum8) Encode

func (col *Enum8) Encode(buffer *proto.Buffer)

func (*Enum8) Name

func (col *Enum8) Name() string

func (*Enum8) Reset

func (col *Enum8) Reset()

func (*Enum8) Row

func (col *Enum8) Row(i int, ptr bool) interface{}

func (*Enum8) Rows

func (col *Enum8) Rows() int

func (*Enum8) ScanRow

func (col *Enum8) ScanRow(dest interface{}, row int) error

func (*Enum8) ScanType

func (col *Enum8) ScanType() reflect.Type

func (*Enum8) Type

func (col *Enum8) Type() Type

type Error

type Error struct {
	ColumnType string
	Err        error
}

func (*Error) Error

func (e *Error) Error() string

type FixedString

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

func (*FixedString) Append

func (col *FixedString) Append(v interface{}) (nulls []uint8, err error)

func (*FixedString) AppendRow

func (col *FixedString) AppendRow(v interface{}) (err error)

func (*FixedString) Decode

func (col *FixedString) Decode(reader *proto.Reader, rows int) error

func (*FixedString) Encode

func (col *FixedString) Encode(buffer *proto.Buffer)

func (*FixedString) Name

func (col *FixedString) Name() string

func (*FixedString) Reset

func (col *FixedString) Reset()

func (*FixedString) Row

func (col *FixedString) Row(i int, ptr bool) interface{}

func (*FixedString) Rows

func (col *FixedString) Rows() int

func (*FixedString) ScanRow

func (col *FixedString) ScanRow(dest interface{}, row int) error

func (*FixedString) ScanType

func (col *FixedString) ScanType() reflect.Type

func (*FixedString) Type

func (col *FixedString) Type() Type

type Float32

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

func (*Float32) Append

func (col *Float32) Append(v interface{}) (nulls []uint8, err error)

func (*Float32) AppendRow

func (col *Float32) AppendRow(v interface{}) error

func (*Float32) Decode

func (col *Float32) Decode(reader *proto.Reader, rows int) error

func (*Float32) Encode

func (col *Float32) Encode(buffer *proto.Buffer)

func (*Float32) Name

func (col *Float32) Name() string

func (*Float32) Reset

func (col *Float32) Reset()

func (*Float32) Row

func (col *Float32) Row(i int, ptr bool) interface{}

func (*Float32) Rows

func (col *Float32) Rows() int

func (*Float32) ScanRow

func (col *Float32) ScanRow(dest interface{}, row int) error

func (*Float32) ScanType

func (col *Float32) ScanType() reflect.Type

func (*Float32) Type

func (col *Float32) Type() Type

type Float64

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

func (*Float64) Append

func (col *Float64) Append(v interface{}) (nulls []uint8, err error)

func (*Float64) AppendRow

func (col *Float64) AppendRow(v interface{}) error

func (*Float64) Decode

func (col *Float64) Decode(reader *proto.Reader, rows int) error

func (*Float64) Encode

func (col *Float64) Encode(buffer *proto.Buffer)

func (*Float64) Name

func (col *Float64) Name() string

func (*Float64) Reset

func (col *Float64) Reset()

func (*Float64) Row

func (col *Float64) Row(i int, ptr bool) interface{}

func (*Float64) Rows

func (col *Float64) Rows() int

func (*Float64) ScanRow

func (col *Float64) ScanRow(dest interface{}, row int) error

func (*Float64) ScanType

func (col *Float64) ScanType() reflect.Type

func (*Float64) Type

func (col *Float64) Type() Type

type IPv4

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

func (*IPv4) Append

func (col *IPv4) Append(v interface{}) (nulls []uint8, err error)

func (*IPv4) AppendRow

func (col *IPv4) AppendRow(v interface{}) (err error)

func (*IPv4) AppendV4IPs

func (col *IPv4) AppendV4IPs(ips []netip.Addr)

func (*IPv4) Decode

func (col *IPv4) Decode(reader *proto.Reader, rows int) error

func (*IPv4) Encode

func (col *IPv4) Encode(buffer *proto.Buffer)

func (*IPv4) Name

func (col *IPv4) Name() string

func (*IPv4) Reset

func (col *IPv4) Reset()

func (*IPv4) Row

func (col *IPv4) Row(i int, ptr bool) interface{}

func (*IPv4) Rows

func (col *IPv4) Rows() int

func (*IPv4) ScanRow

func (col *IPv4) ScanRow(dest interface{}, row int) error

func (*IPv4) ScanType

func (col *IPv4) ScanType() reflect.Type

func (*IPv4) Type

func (col *IPv4) Type() Type

type IPv6

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

func (*IPv6) Append

func (col *IPv6) Append(v interface{}) (nulls []uint8, err error)

func (*IPv6) AppendRow

func (col *IPv6) AppendRow(v interface{}) (err error)

func (*IPv6) AppendV6IPs

func (col *IPv6) AppendV6IPs(ips []netip.Addr)

func (*IPv6) Decode

func (col *IPv6) Decode(reader *proto.Reader, rows int) error

func (*IPv6) Encode

func (col *IPv6) Encode(buffer *proto.Buffer)

func (*IPv6) Name

func (col *IPv6) Name() string

func (*IPv6) Reset

func (col *IPv6) Reset()

func (*IPv6) Row

func (col *IPv6) Row(i int, ptr bool) interface{}

func (*IPv6) Rows

func (col *IPv6) Rows() int

func (*IPv6) ScanRow

func (col *IPv6) ScanRow(dest interface{}, row int) error

func (*IPv6) ScanType

func (col *IPv6) ScanType() reflect.Type

func (*IPv6) Type

func (col *IPv6) Type() Type

type Int16

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

func (*Int16) Append

func (col *Int16) Append(v interface{}) (nulls []uint8, err error)

func (*Int16) AppendRow

func (col *Int16) AppendRow(v interface{}) error

func (*Int16) Decode

func (col *Int16) Decode(reader *proto.Reader, rows int) error

func (*Int16) Encode

func (col *Int16) Encode(buffer *proto.Buffer)

func (*Int16) Name

func (col *Int16) Name() string

func (*Int16) Reset

func (col *Int16) Reset()

func (*Int16) Row

func (col *Int16) Row(i int, ptr bool) interface{}

func (*Int16) Rows

func (col *Int16) Rows() int

func (*Int16) ScanRow

func (col *Int16) ScanRow(dest interface{}, row int) error

func (*Int16) ScanType

func (col *Int16) ScanType() reflect.Type

func (*Int16) Type

func (col *Int16) Type() Type

type Int32

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

func (*Int32) Append

func (col *Int32) Append(v interface{}) (nulls []uint8, err error)

func (*Int32) AppendRow

func (col *Int32) AppendRow(v interface{}) error

func (*Int32) Decode

func (col *Int32) Decode(reader *proto.Reader, rows int) error

func (*Int32) Encode

func (col *Int32) Encode(buffer *proto.Buffer)

func (*Int32) Name

func (col *Int32) Name() string

func (*Int32) Reset

func (col *Int32) Reset()

func (*Int32) Row

func (col *Int32) Row(i int, ptr bool) interface{}

func (*Int32) Rows

func (col *Int32) Rows() int

func (*Int32) ScanRow

func (col *Int32) ScanRow(dest interface{}, row int) error

func (*Int32) ScanType

func (col *Int32) ScanType() reflect.Type

func (*Int32) Type

func (col *Int32) Type() Type

type Int64

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

func (*Int64) Append

func (col *Int64) Append(v interface{}) (nulls []uint8, err error)

func (*Int64) AppendRow

func (col *Int64) AppendRow(v interface{}) error

func (*Int64) Decode

func (col *Int64) Decode(reader *proto.Reader, rows int) error

func (*Int64) Encode

func (col *Int64) Encode(buffer *proto.Buffer)

func (*Int64) Name

func (col *Int64) Name() string

func (*Int64) Reset

func (col *Int64) Reset()

func (*Int64) Row

func (col *Int64) Row(i int, ptr bool) interface{}

func (*Int64) Rows

func (col *Int64) Rows() int

func (*Int64) ScanRow

func (col *Int64) ScanRow(dest interface{}, row int) error

func (*Int64) ScanType

func (col *Int64) ScanType() reflect.Type

func (*Int64) Type

func (col *Int64) Type() Type

type Int8

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

func (*Int8) Append

func (col *Int8) Append(v interface{}) (nulls []uint8, err error)

func (*Int8) AppendRow

func (col *Int8) AppendRow(v interface{}) error

func (*Int8) Decode

func (col *Int8) Decode(reader *proto.Reader, rows int) error

func (*Int8) Encode

func (col *Int8) Encode(buffer *proto.Buffer)

func (*Int8) Name

func (col *Int8) Name() string

func (*Int8) Reset

func (col *Int8) Reset()

func (*Int8) Row

func (col *Int8) Row(i int, ptr bool) interface{}

func (*Int8) Rows

func (col *Int8) Rows() int

func (*Int8) ScanRow

func (col *Int8) ScanRow(dest interface{}, row int) error

func (*Int8) ScanType

func (col *Int8) ScanType() reflect.Type

func (*Int8) Type

func (col *Int8) Type() Type

type Interface

type Interface interface {
	Name() string
	Type() Type
	Rows() int
	Row(i int, ptr bool) interface{}
	ScanRow(dest interface{}, row int) error
	Append(v interface{}) (nulls []uint8, err error)
	AppendRow(v interface{}) error
	Decode(reader *proto.Reader, rows int) error
	Encode(buffer *proto.Buffer)
	ScanType() reflect.Type
	Reset()
}

func Enum

func Enum(chType Type, name string) (Interface, error)

type Interval

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

func (Interval) Append

func (Interval) Append(interface{}) ([]uint8, error)

func (Interval) AppendRow

func (Interval) AppendRow(interface{}) error

func (*Interval) Decode

func (col *Interval) Decode(reader *proto.Reader, rows int) error

func (Interval) Encode

func (Interval) Encode(buffer *proto.Buffer)

func (*Interval) Name

func (col *Interval) Name() string

func (*Interval) Reset

func (col *Interval) Reset()

func (*Interval) Row

func (col *Interval) Row(i int, ptr bool) interface{}

func (*Interval) Rows

func (col *Interval) Rows() int

func (*Interval) ScanRow

func (col *Interval) ScanRow(dest interface{}, row int) error

func (*Interval) ScanType

func (col *Interval) ScanType() reflect.Type

func (*Interval) Type

func (col *Interval) Type() Type

type JSON

type JSON interface {
	Interface
	// contains filtered or unexported methods
}

type JSONList

type JSONList struct {
	Array
	// contains filtered or unexported fields
}

func (*JSONList) Name

func (jCol *JSONList) Name() string

func (*JSONList) Type

func (jCol *JSONList) Type() Type

type JSONObject

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

func (*JSONObject) Append

func (jCol *JSONObject) Append(v interface{}) (nulls []uint8, err error)

func (*JSONObject) AppendRow

func (jCol *JSONObject) AppendRow(v interface{}) error

func (*JSONObject) Decode

func (jCol *JSONObject) Decode(reader *proto.Reader, rows int) error

func (*JSONObject) Encode

func (jCol *JSONObject) Encode(buffer *proto.Buffer)

func (*JSONObject) FullType

func (jCol *JSONObject) FullType() Type

func (*JSONObject) Name

func (jCol *JSONObject) Name() string

func (*JSONObject) ReadStatePrefix

func (jCol *JSONObject) ReadStatePrefix(reader *proto.Reader) error

func (*JSONObject) Reset

func (jCol *JSONObject) Reset()

func (*JSONObject) Row

func (jCol *JSONObject) Row(i int, ptr bool) interface{}

func (*JSONObject) Rows

func (jCol *JSONObject) Rows() int

func (*JSONObject) ScanRow

func (jCol *JSONObject) ScanRow(dest interface{}, row int) error

func (*JSONObject) ScanType

func (jCol *JSONObject) ScanType() reflect.Type

func (*JSONObject) Type

func (jCol *JSONObject) Type() Type

func (*JSONObject) WriteStatePrefix

func (jCol *JSONObject) WriteStatePrefix(buffer *proto.Buffer) error

type JSONParent

type JSONParent interface {
	// contains filtered or unexported methods
}

type JSONValue

type JSONValue struct {
	Interface
	// contains filtered or unexported fields
}

func (*JSONValue) Reset

func (jCol *JSONValue) Reset()

func (*JSONValue) Type

func (jCol *JSONValue) Type() Type

type LowCardinality

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

https://github.com/ClickHouse/ClickHouse/blob/master/src/Columns/ColumnLowCardinality.cpp https://github.com/ClickHouse/clickhouse-cpp/blob/master/clickhouse/columns/lowcardinality.cpp

func (*LowCardinality) Append

func (col *LowCardinality) Append(v interface{}) (nulls []uint8, err error)

func (*LowCardinality) AppendRow

func (col *LowCardinality) AppendRow(v interface{}) error

func (*LowCardinality) Decode

func (col *LowCardinality) Decode(reader *proto.Reader, rows int) error

func (*LowCardinality) Encode

func (col *LowCardinality) Encode(buffer *proto.Buffer)

func (*LowCardinality) Name

func (col *LowCardinality) Name() string

func (*LowCardinality) ReadStatePrefix

func (col *LowCardinality) ReadStatePrefix(reader *proto.Reader) error

func (*LowCardinality) Reset

func (col *LowCardinality) Reset()

func (*LowCardinality) Row

func (col *LowCardinality) Row(i int, ptr bool) interface{}

func (*LowCardinality) Rows

func (col *LowCardinality) Rows() int

func (*LowCardinality) ScanRow

func (col *LowCardinality) ScanRow(dest interface{}, row int) error

func (*LowCardinality) ScanType

func (col *LowCardinality) ScanType() reflect.Type

func (*LowCardinality) Type

func (col *LowCardinality) Type() Type

func (*LowCardinality) WriteStatePrefix

func (col *LowCardinality) WriteStatePrefix(buffer *proto.Buffer) error

type Map

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

https://github.com/ClickHouse/ClickHouse/blob/master/src/Columns/ColumnMap.cpp

func (*Map) Append

func (col *Map) Append(v interface{}) (nulls []uint8, err error)

func (*Map) AppendRow

func (col *Map) AppendRow(v interface{}) error

func (*Map) Decode

func (col *Map) Decode(reader *proto.Reader, rows int) error

func (*Map) Encode

func (col *Map) Encode(buffer *proto.Buffer)

func (*Map) Name

func (col *Map) Name() string

func (*Map) ReadStatePrefix

func (col *Map) ReadStatePrefix(reader *proto.Reader) error

func (*Map) Reset

func (col *Map) Reset()

func (*Map) Row

func (col *Map) Row(i int, ptr bool) interface{}

func (*Map) Rows

func (col *Map) Rows() int

func (*Map) ScanRow

func (col *Map) ScanRow(dest interface{}, i int) error

func (*Map) ScanType

func (col *Map) ScanType() reflect.Type

func (*Map) Type

func (col *Map) Type() Type

func (*Map) WriteStatePrefix

func (col *Map) WriteStatePrefix(encoder *proto.Buffer) error

type MultiPolygon

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

func (*MultiPolygon) Append

func (col *MultiPolygon) Append(v interface{}) (nulls []uint8, err error)

func (*MultiPolygon) AppendRow

func (col *MultiPolygon) AppendRow(v interface{}) error

func (*MultiPolygon) Decode

func (col *MultiPolygon) Decode(reader *proto.Reader, rows int) error

func (*MultiPolygon) Encode

func (col *MultiPolygon) Encode(buffer *proto.Buffer)

func (*MultiPolygon) Name

func (col *MultiPolygon) Name() string

func (*MultiPolygon) Reset

func (col *MultiPolygon) Reset()

func (*MultiPolygon) Row

func (col *MultiPolygon) Row(i int, ptr bool) interface{}

func (*MultiPolygon) Rows

func (col *MultiPolygon) Rows() int

func (*MultiPolygon) ScanRow

func (col *MultiPolygon) ScanRow(dest interface{}, row int) error

func (*MultiPolygon) ScanType

func (col *MultiPolygon) ScanType() reflect.Type

func (*MultiPolygon) Type

func (col *MultiPolygon) Type() Type

type Nested

type Nested struct {
	Interface
	// contains filtered or unexported fields
}

func (*Nested) Reset

func (col *Nested) Reset()

type Nothing

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

func (Nothing) Append

func (Nothing) Append(interface{}) ([]uint8, error)

func (Nothing) AppendRow

func (col Nothing) AppendRow(interface{}) error

func (Nothing) Decode

func (col Nothing) Decode(reader *proto.Reader, rows int) error

func (Nothing) Encode

func (Nothing) Encode(buffer *proto.Buffer)

func (Nothing) Name

func (col Nothing) Name() string

func (*Nothing) Reset

func (col *Nothing) Reset()

func (Nothing) Row

func (Nothing) Row(int, bool) interface{}

func (Nothing) Rows

func (Nothing) Rows() int

func (Nothing) ScanRow

func (Nothing) ScanRow(interface{}, int) error

func (Nothing) ScanType

func (Nothing) ScanType() reflect.Type

func (Nothing) Type

func (Nothing) Type() Type

type Nullable

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

func (*Nullable) Append

func (col *Nullable) Append(v interface{}) ([]uint8, error)

func (*Nullable) AppendRow

func (col *Nullable) AppendRow(v interface{}) error

func (*Nullable) Base

func (col *Nullable) Base() Interface

func (*Nullable) Decode

func (col *Nullable) Decode(reader *proto.Reader, rows int) error

func (*Nullable) Encode

func (col *Nullable) Encode(buffer *proto.Buffer)

func (*Nullable) Name

func (col *Nullable) Name() string

func (*Nullable) Reset

func (col *Nullable) Reset()

func (*Nullable) Row

func (col *Nullable) Row(i int, ptr bool) interface{}

func (*Nullable) Rows

func (col *Nullable) Rows() int

func (*Nullable) ScanRow

func (col *Nullable) ScanRow(dest interface{}, row int) error

func (*Nullable) ScanType

func (col *Nullable) ScanType() reflect.Type

func (*Nullable) Type

func (col *Nullable) Type() Type

type OrderedMap

type OrderedMap interface {
	Get(key interface{}) (interface{}, bool)
	Put(key interface{}, value interface{})
	Keys() <-chan interface{}
}

type Point

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

func (*Point) Append

func (col *Point) Append(v interface{}) (nulls []uint8, err error)

func (*Point) AppendRow

func (col *Point) AppendRow(v interface{}) error

func (*Point) Decode

func (col *Point) Decode(reader *proto.Reader, rows int) error

func (*Point) Encode

func (col *Point) Encode(buffer *proto.Buffer)

func (*Point) Name

func (col *Point) Name() string

func (*Point) Reset

func (col *Point) Reset()

func (*Point) Row

func (col *Point) Row(i int, ptr bool) interface{}

func (*Point) Rows

func (col *Point) Rows() int

func (*Point) ScanRow

func (col *Point) ScanRow(dest interface{}, row int) error

func (*Point) ScanType

func (col *Point) ScanType() reflect.Type

func (*Point) Type

func (col *Point) Type() Type

type Polygon

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

func (*Polygon) Append

func (col *Polygon) Append(v interface{}) (nulls []uint8, err error)

func (*Polygon) AppendRow

func (col *Polygon) AppendRow(v interface{}) error

func (*Polygon) Decode

func (col *Polygon) Decode(reader *proto.Reader, rows int) error

func (*Polygon) Encode

func (col *Polygon) Encode(buffer *proto.Buffer)

func (*Polygon) Name

func (col *Polygon) Name() string

func (*Polygon) Reset

func (col *Polygon) Reset()

func (*Polygon) Row

func (col *Polygon) Row(i int, ptr bool) interface{}

func (*Polygon) Rows

func (col *Polygon) Rows() int

func (*Polygon) ScanRow

func (col *Polygon) ScanRow(dest interface{}, row int) error

func (*Polygon) ScanType

func (col *Polygon) ScanType() reflect.Type

func (*Polygon) Type

func (col *Polygon) Type() Type

type Ring

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

func (*Ring) Append

func (col *Ring) Append(v interface{}) (nulls []uint8, err error)

func (*Ring) AppendRow

func (col *Ring) AppendRow(v interface{}) error

func (*Ring) Decode

func (col *Ring) Decode(reader *proto.Reader, rows int) error

func (*Ring) Encode

func (col *Ring) Encode(buffer *proto.Buffer)

func (*Ring) Name

func (col *Ring) Name() string

func (*Ring) Reset

func (col *Ring) Reset()

func (*Ring) Row

func (col *Ring) Row(i int, ptr bool) interface{}

func (*Ring) Rows

func (col *Ring) Rows() int

func (*Ring) ScanRow

func (col *Ring) ScanRow(dest interface{}, row int) error

func (*Ring) ScanType

func (col *Ring) ScanType() reflect.Type

func (*Ring) Type

func (col *Ring) Type() Type

type SimpleAggregateFunction

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

func (*SimpleAggregateFunction) Append

func (col *SimpleAggregateFunction) Append(v interface{}) ([]uint8, error)

func (*SimpleAggregateFunction) AppendRow

func (col *SimpleAggregateFunction) AppendRow(v interface{}) error

func (*SimpleAggregateFunction) Decode

func (col *SimpleAggregateFunction) Decode(reader *proto.Reader, rows int) error

func (*SimpleAggregateFunction) Encode

func (col *SimpleAggregateFunction) Encode(buffer *proto.Buffer)

func (*SimpleAggregateFunction) Name

func (col *SimpleAggregateFunction) Name() string

func (*SimpleAggregateFunction) Reset

func (col *SimpleAggregateFunction) Reset()

func (*SimpleAggregateFunction) Row

func (col *SimpleAggregateFunction) Row(i int, ptr bool) interface{}

func (*SimpleAggregateFunction) Rows

func (col *SimpleAggregateFunction) Rows() int

func (*SimpleAggregateFunction) ScanRow

func (col *SimpleAggregateFunction) ScanRow(dest interface{}, rows int) error

func (*SimpleAggregateFunction) ScanType

func (col *SimpleAggregateFunction) ScanType() reflect.Type

func (*SimpleAggregateFunction) Type

func (col *SimpleAggregateFunction) Type() Type

type String

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

func (*String) Append

func (col *String) Append(v interface{}) (nulls []uint8, err error)

func (*String) AppendRow

func (col *String) AppendRow(v interface{}) error

func (*String) Decode

func (col *String) Decode(reader *proto.Reader, rows int) error

func (*String) Encode

func (col *String) Encode(buffer *proto.Buffer)

func (String) Name

func (col String) Name() string

func (*String) Reset

func (col *String) Reset()

func (*String) Row

func (col *String) Row(i int, ptr bool) interface{}

func (*String) Rows

func (col *String) Rows() int

func (*String) ScanRow

func (col *String) ScanRow(dest interface{}, row int) error

func (String) ScanType

func (String) ScanType() reflect.Type

func (String) Type

func (String) Type() Type

type Tuple

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

func (*Tuple) Append

func (col *Tuple) Append(v interface{}) (nulls []uint8, err error)

func (*Tuple) AppendRow

func (col *Tuple) AppendRow(v interface{}) error

func (*Tuple) Decode

func (col *Tuple) Decode(reader *proto.Reader, rows int) error

func (*Tuple) Encode

func (col *Tuple) Encode(buffer *proto.Buffer)

func (*Tuple) Name

func (col *Tuple) Name() string

func (*Tuple) ReadStatePrefix

func (col *Tuple) ReadStatePrefix(reader *proto.Reader) error

func (*Tuple) Reset

func (col *Tuple) Reset()

func (*Tuple) Row

func (col *Tuple) Row(i int, ptr bool) interface{}

func (*Tuple) Rows

func (col *Tuple) Rows() int

func (*Tuple) ScanRow

func (col *Tuple) ScanRow(dest interface{}, row int) error

func (Tuple) ScanType

func (col Tuple) ScanType() reflect.Type

func (*Tuple) Type

func (col *Tuple) Type() Type

func (*Tuple) WriteStatePrefix

func (col *Tuple) WriteStatePrefix(buffer *proto.Buffer) error

type Type

type Type string

func (Type) Column

func (t Type) Column(name string, tz *time.Location) (Interface, error)

type UInt16

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

func (*UInt16) Append

func (col *UInt16) Append(v interface{}) (nulls []uint8, err error)

func (*UInt16) AppendRow

func (col *UInt16) AppendRow(v interface{}) error

func (*UInt16) Decode

func (col *UInt16) Decode(reader *proto.Reader, rows int) error

func (*UInt16) Encode

func (col *UInt16) Encode(buffer *proto.Buffer)

func (*UInt16) Name

func (col *UInt16) Name() string

func (*UInt16) Reset

func (col *UInt16) Reset()

func (*UInt16) Row

func (col *UInt16) Row(i int, ptr bool) interface{}

func (*UInt16) Rows

func (col *UInt16) Rows() int

func (*UInt16) ScanRow

func (col *UInt16) ScanRow(dest interface{}, row int) error

func (*UInt16) ScanType

func (col *UInt16) ScanType() reflect.Type

func (*UInt16) Type

func (col *UInt16) Type() Type

type UInt32

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

func (*UInt32) Append

func (col *UInt32) Append(v interface{}) (nulls []uint8, err error)

func (*UInt32) AppendRow

func (col *UInt32) AppendRow(v interface{}) error

func (*UInt32) Decode

func (col *UInt32) Decode(reader *proto.Reader, rows int) error

func (*UInt32) Encode

func (col *UInt32) Encode(buffer *proto.Buffer)

func (*UInt32) Name

func (col *UInt32) Name() string

func (*UInt32) Reset

func (col *UInt32) Reset()

func (*UInt32) Row

func (col *UInt32) Row(i int, ptr bool) interface{}

func (*UInt32) Rows

func (col *UInt32) Rows() int

func (*UInt32) ScanRow

func (col *UInt32) ScanRow(dest interface{}, row int) error

func (*UInt32) ScanType

func (col *UInt32) ScanType() reflect.Type

func (*UInt32) Type

func (col *UInt32) Type() Type

type UInt64

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

func (*UInt64) Append

func (col *UInt64) Append(v interface{}) (nulls []uint8, err error)

func (*UInt64) AppendRow

func (col *UInt64) AppendRow(v interface{}) error

func (*UInt64) Decode

func (col *UInt64) Decode(reader *proto.Reader, rows int) error

func (*UInt64) Encode

func (col *UInt64) Encode(buffer *proto.Buffer)

func (*UInt64) Name

func (col *UInt64) Name() string

func (*UInt64) Reset

func (col *UInt64) Reset()

func (*UInt64) Row

func (col *UInt64) Row(i int, ptr bool) interface{}

func (*UInt64) Rows

func (col *UInt64) Rows() int

func (*UInt64) ScanRow

func (col *UInt64) ScanRow(dest interface{}, row int) error

func (*UInt64) ScanType

func (col *UInt64) ScanType() reflect.Type

func (*UInt64) Type

func (col *UInt64) Type() Type

type UInt8

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

func (*UInt8) Append

func (col *UInt8) Append(v interface{}) (nulls []uint8, err error)

func (*UInt8) AppendRow

func (col *UInt8) AppendRow(v interface{}) error

func (*UInt8) Decode

func (col *UInt8) Decode(reader *proto.Reader, rows int) error

func (*UInt8) Encode

func (col *UInt8) Encode(buffer *proto.Buffer)

func (*UInt8) Name

func (col *UInt8) Name() string

func (*UInt8) Reset

func (col *UInt8) Reset()

func (*UInt8) Row

func (col *UInt8) Row(i int, ptr bool) interface{}

func (*UInt8) Rows

func (col *UInt8) Rows() int

func (*UInt8) ScanRow

func (col *UInt8) ScanRow(dest interface{}, row int) error

func (*UInt8) ScanType

func (col *UInt8) ScanType() reflect.Type

func (*UInt8) Type

func (col *UInt8) Type() Type

type UUID

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

func (*UUID) Append

func (col *UUID) Append(v interface{}) (nulls []uint8, err error)

func (*UUID) AppendRow

func (col *UUID) AppendRow(v interface{}) error

func (*UUID) Decode

func (col *UUID) Decode(reader *proto.Reader, rows int) error

func (*UUID) Encode

func (col *UUID) Encode(buffer *proto.Buffer)

func (*UUID) Name

func (col *UUID) Name() string

func (*UUID) Reset

func (col *UUID) Reset()

func (*UUID) Row

func (col *UUID) Row(i int, ptr bool) interface{}

func (*UUID) Rows

func (col *UUID) Rows() int

func (*UUID) ScanRow

func (col *UUID) ScanRow(dest interface{}, row int) error

func (*UUID) ScanType

func (col *UUID) ScanType() reflect.Type

func (*UUID) Type

func (col *UUID) Type() Type

type UnsupportedColumnTypeError

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

func (*UnsupportedColumnTypeError) Error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL