helper

Documentation

Index

• func ArrowToClickHouse(t arrow.DataType) string
• func ArrowToCockroach(t arrow.DataType) string
• func ArrowToPg10(t arrow.DataType) string
• func GetValue(column arrow.Array, rowIndex int) interface{}
• func InferArrowType(value interface{}) arrow.DataType
• func IsPrimitiveType(fieldType string) bool
• func MapPlainTypeToArrow(fieldType string) arrow.DataType
• func NormalizeStreamName(stream string) string

Functions

func ArrowToClickHouse

func ArrowToClickHouse(t arrow.DataType) string

func ArrowToCockroach

func ArrowToCockroach(t arrow.DataType) string

ArrowToCockroach converts arrow data type to cockroach data type. CockroachDB lacks support for some data types like macaddr and has different aliases for ints. See: https://www.cockroachlabs.com/docs/stable/int.html

func ArrowToPg10

func ArrowToPg10(t arrow.DataType) string

func GetValue

func GetValue(column arrow.Array, rowIndex int) interface{}

GetValue extracts the value at the specified row index from a column using reflection

func InferArrowType

func InferArrowType(value interface{}) arrow.DataType

func IsPrimitiveType

func IsPrimitiveType(fieldType string) bool

func MapPlainTypeToArrow

func MapPlainTypeToArrow(fieldType string) arrow.DataType

func NormalizeStreamName

func NormalizeStreamName(stream string) string