data_types

package

v2.0.13 Latest Latest Go to latest Published: Apr 28, 2025 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gigapi/gigapi

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func FastFillArray[T any](arr []T, data T) []T
type Column
type ColumnBuilder
type IArrowAppender
type IColumn
- func WrapToColumn(name string, data any) (IColumn, error)
type IndexType
type UnknownType

Constants ¶

View Source

const DATA_TYPE_NAME_FLOAT64 = "FLOAT8"

View Source

const DATA_TYPE_NAME_INT64 = "INT8"

View Source

const DATA_TYPE_NAME_STRING = "VARCHAR"

View Source

const DATA_TYPE_NAME_UINT64 = "UBIGINT"

View Source

const DATA_TYPE_NAME_UNKNOWN = "UNKNOWN"

Variables ¶

View Source

var DataTypes = map[string]ColumnBuilder{
	"Int64":  int64Builder,
	"BIGINT": int64Builder,
	"INT8":   int64Builder,
	"LONG":   int64Builder,

	"UInt64":  uint64Builder,
	"UBIGINT": uint64Builder,

	"Float64": float64Builder,
	"DOUBLE":  float64Builder,
	"FLOAT8":  float64Builder,

	"String":  strBuilder,
	"STRING":  strBuilder,
	"VARCHAR": strBuilder,
	"CHAR":    strBuilder,
	"BPCHAR":  strBuilder,
	"TEXT":    strBuilder,
}

Functions ¶

func FastFillArray ¶

func FastFillArray[T any](arr []T, data T) []T

Types ¶

type Column ¶

type Column[T constraints.Ordered] struct {
	// contains filtered or unexported fields
}

func (*Column[T]) Append ¶

func (c *Column[T]) Append(data any) error

func (*Column[T]) AppendByMask ¶

func (c *Column[T]) AppendByMask(data any, mask []byte) error

func (*Column[T]) AppendFromJson ¶

func (c *Column[T]) AppendFromJson(dec *jx.Decoder) error

func (*Column[T]) AppendNulls ¶

func (c *Column[T]) AppendNulls(size int64)

func (*Column[T]) AppendOne ¶

func (c *Column[T]) AppendOne(val any) error

func (*Column[T]) ArrowDataType ¶

func (c *Column[T]) ArrowDataType() arrow.DataType

func (*Column[T]) GetData ¶

func (c *Column[T]) GetData() any

func (*Column[T]) GetLength ¶

func (c *Column[T]) GetLength() int64

func (*Column[T]) GetMinMax ¶

func (c *Column[T]) GetMinMax() (any, any)

func (*Column[T]) GetName ¶

func (c *Column[T]) GetName() string

func (*Column[T]) GetTypeName ¶

func (c *Column[T]) GetTypeName() string

func (*Column[T]) GetVal ¶

func (c *Column[T]) GetVal(i int64) any

func (*Column[T]) InitializeData ¶

func (c *Column[T]) InitializeData(sizeAndCap ...int64)

func (*Column[T]) Less ¶

func (c *Column[T]) Less(i int32, j int32) bool

func (*Column[T]) ParseFromStr ¶

func (c *Column[T]) ParseFromStr(s string) error

func (*Column[T]) ValidateData ¶

func (c *Column[T]) ValidateData(data any) error

func (*Column[T]) WriteToBatch ¶

func (c *Column[T]) WriteToBatch(batch array.Builder) error

type ColumnBuilder ¶

type ColumnBuilder func(name string, data any, sizeAndCap ...int64) (IColumn, error)

type IArrowAppender ¶

type IArrowAppender[T constraints.Ordered] interface {
	AppendValues(values []T, valid []bool)
}

type IColumn ¶

type IColumn interface {
	AppendNulls(size int64)
	GetLength() int64
	AppendFromJson(dec *jx.Decoder) error
	Less(i int32, j int32) bool
	ValidateData(data any) error
	ArrowDataType() arrow.DataType
	Append(data any) error
	AppendOne(val any) error
	AppendByMask(data any, mask []byte) error
	WriteToBatch(batch array.Builder) error
	GetName() string
	GetTypeName() string
	GetVal(i int64) any
	ParseFromStr(s string) error
	GetData() any
	GetMinMax() (any, any)
}

func WrapToColumn ¶

func WrapToColumn(name string, data any) (IColumn, error)

type IndexType ¶

type IndexType []int32

type UnknownType ¶

type UnknownType struct{}

func (UnknownType) AppendByMask ¶

func (u UnknownType) AppendByMask(data any, toAppend any, mask []byte) (any, error)

func (UnknownType) AppendDefault ¶

func (u UnknownType) AppendDefault(size int, store any) any

func (UnknownType) AppendOne ¶

func (u UnknownType) AppendOne(val any, data any) any

func (UnknownType) AppendStore ¶

func (u UnknownType) AppendStore(store any, data any) (any, error)

func (UnknownType) ArrowDataType ¶

func (u UnknownType) ArrowDataType() arrow.DataType

func (UnknownType) BLess ¶

func (f UnknownType) BLess(a any, b any) bool

func (UnknownType) GetLength ¶

func (u UnknownType) GetLength(store any) int64

func (UnknownType) GetMerger ¶

func (u UnknownType) GetMerger(data1 any, valid1 []bool, data2 any, valid2 []bool, s1 int64, s2 int64) any

func (UnknownType) GetName ¶

func (u UnknownType) GetName() string

func (UnknownType) GetSorter ¶

func (u UnknownType) GetSorter(data any) sort.Interface

func (UnknownType) GetVal ¶

func (u UnknownType) GetVal(i int64, store any) any

func (UnknownType) GetValI32 ¶

func (u UnknownType) GetValI32(i int32, store any) any

func (UnknownType) Less ¶

func (u UnknownType) Less(store any, i int32, j int32) bool

func (UnknownType) MakeStore ¶

func (u UnknownType) MakeStore(sizeAndCap ...int) any

func (UnknownType) ParseFromStr ¶

func (u UnknownType) ParseFromStr(s string) (any, error)

func (UnknownType) ParseJson ¶

func (u UnknownType) ParseJson(dec *jx.Decoder, store any) (any, error)

func (UnknownType) ValidateData ¶

func (u UnknownType) ValidateData(data any) error

func (UnknownType) WriteToBatch ¶

func (u UnknownType) WriteToBatch(batch array.Builder, data any, indexes IndexType, valid []bool) error

Source Files ¶

View all Source files

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