arrow

package
v0.0.0-...-7a29347 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2024 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 3 more Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildArray 

func BuildArray(c *client.IPCClient, arr arrow.Array) (types.ObjectID, error)

Types

type Array 

type Array interface {
	client.IObject
	GetArray() arrow.Array
}

func ConstructArray 

func ConstructArray(c *client.IPCClient, meta *client.ObjectMeta) (array Array, err error)

type Float32Array 

type Float32Array struct {
	client.Object
	*array.Float32
	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func (*Float32Array) Construct 

func (arr *Float32Array) Construct(c *client.IPCClient, meta *client.ObjectMeta) (err error)

func (*Float32Array) GetArray 

func (arr *Float32Array) GetArray() arrow.Array

type Float32Builder 

type Float32Builder struct {
	*array.Float32Builder
	*array.Float32

	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func NewFloat32Builder 

func NewFloat32Builder() *Float32Builder

func NewFloat32BuilderFromArray 

func NewFloat32BuilderFromArray(array *array.Float32) *Float32Builder

func (*Float32Builder) Build 

func (arr *Float32Builder) Build(client *client.IPCClient) (err error)

func (*Float32Builder) Seal 

func (arr *Float32Builder) Seal(c *client.IPCClient) (types.ObjectID, error)

type Float64Array 

type Float64Array struct {
	client.Object
	*array.Float64
	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func (*Float64Array) Construct 

func (arr *Float64Array) Construct(c *client.IPCClient, meta *client.ObjectMeta) (err error)

func (*Float64Array) GetArray 

func (arr *Float64Array) GetArray() arrow.Array

type Float64Builder 

type Float64Builder struct {
	*array.Float64Builder
	*array.Float64

	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func NewFloat64Builder 

func NewFloat64Builder() *Float64Builder

func NewFloat64BuilderFromArray 

func NewFloat64BuilderFromArray(array *array.Float64) *Float64Builder

func (*Float64Builder) Build 

func (arr *Float64Builder) Build(client *client.IPCClient) (err error)

func (*Float64Builder) Seal 

func (arr *Float64Builder) Seal(c *client.IPCClient) (types.ObjectID, error)

type Int32Array 

type Int32Array struct {
	client.Object
	*array.Int32
	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func (*Int32Array) Construct 

func (arr *Int32Array) Construct(c *client.IPCClient, meta *client.ObjectMeta) (err error)

func (*Int32Array) GetArray 

func (arr *Int32Array) GetArray() arrow.Array

type Int32Builder 

type Int32Builder struct {
	*array.Int32Builder
	*array.Int32

	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func NewInt32Builder 

func NewInt32Builder() *Int32Builder

func NewInt32BuilderFromArray 

func NewInt32BuilderFromArray(array *array.Int32) *Int32Builder

func NewUint32Builder 

func NewUint32Builder() *Int32Builder

func (*Int32Builder) Build 

func (arr *Int32Builder) Build(client *client.IPCClient) (err error)

func (*Int32Builder) Seal 

func (arr *Int32Builder) Seal(c *client.IPCClient) (types.ObjectID, error)

type Int64Array 

type Int64Array struct {
	client.Object
	*array.Int64
	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func (*Int64Array) Construct 

func (arr *Int64Array) Construct(c *client.IPCClient, meta *client.ObjectMeta) (err error)

func (*Int64Array) GetArray 

func (arr *Int64Array) GetArray() arrow.Array

type Int64Builder 

type Int64Builder struct {
	*array.Int64Builder
	*array.Int64

	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func NewInt64Builder 

func NewInt64Builder() *Int64Builder

func NewInt64BuilderFromArray 

func NewInt64BuilderFromArray(array *array.Int64) *Int64Builder

func NewUint64Builder 

func NewUint64Builder() *Int64Builder

func (*Int64Builder) Build 

func (arr *Int64Builder) Build(client *client.IPCClient) (err error)

func (*Int64Builder) Seal 

func (arr *Int64Builder) Seal(c *client.IPCClient) (types.ObjectID, error)

type LargeStringArray 

type LargeStringArray struct {
	client.Object
	*array.LargeString
	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func (*LargeStringArray) Construct 

func (arr *LargeStringArray) Construct(c *client.IPCClient, meta *client.ObjectMeta) (err error)

func (*LargeStringArray) GetArray 

func (arr *LargeStringArray) GetArray() arrow.Array

type LargeStringBuilder 

type LargeStringBuilder struct {
	*array.LargeStringBuilder
	*array.LargeString

	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func NewLargeStringBuilder 

func NewLargeStringBuilder() *LargeStringBuilder

func NewLargeStringBuilderFromArray 

func NewLargeStringBuilderFromArray(array *array.LargeString) *LargeStringBuilder

func (*LargeStringBuilder) Build 

func (arr *LargeStringBuilder) Build(client *client.IPCClient) (err error)

func (*LargeStringBuilder) Seal 

func (arr *LargeStringBuilder) Seal(c *client.IPCClient) (types.ObjectID, error)

type RecordBatch 

type RecordBatch struct {
	client.Object
	arrow.Record
}

func (*RecordBatch) Construct 

func (r *RecordBatch) Construct(c *client.IPCClient, meta *client.ObjectMeta) (err error)

type RecordBuilder 

type RecordBuilder struct {
	*array.RecordBuilder
	arrow.Record

	Schema     *SchemaBuilder
	NumColumns uint64
	NumRows    uint64
	Columns    []types.ObjectID
}

func NewRecordBuilder 

func NewRecordBuilder(schema *arrow.Schema) *RecordBuilder

func NewRecordBuilderFromRecord 

func NewRecordBuilderFromRecord(record arrow.Record) *RecordBuilder

func (*RecordBuilder) Build 

func (r *RecordBuilder) Build(c *client.IPCClient) error

func (*RecordBuilder) Seal 

func (r *RecordBuilder) Seal(c *client.IPCClient) (types.ObjectID, error)

type Schema 

type Schema struct {
	client.Object
	*arrow.Schema
}

func (*Schema) Construct 

func (s *Schema) Construct(c *client.IPCClient, meta *client.ObjectMeta) (err error)

type SchemaBinaryWrapper 

type SchemaBinaryWrapper struct {
	Bytes []int64 `json:"bytes"`
}

type SchemaBuilder 

type SchemaBuilder struct {
	*arrow.Schema
	// contains filtered or unexported fields
}

func NewSchemaBuilder 

func NewSchemaBuilder(schema *arrow.Schema) *SchemaBuilder

func (*SchemaBuilder) Build 

func (s *SchemaBuilder) Build(c *client.IPCClient) error

func (*SchemaBuilder) Seal 

func (s *SchemaBuilder) Seal(c *client.IPCClient) (types.ObjectID, error)

type StringArray 

type StringArray struct {
	client.Object
	*array.String
	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func (*StringArray) Construct 

func (arr *StringArray) Construct(c *client.IPCClient, meta *client.ObjectMeta) (err error)

func (*StringArray) GetArray 

func (arr *StringArray) GetArray() arrow.Array

type StringBuilder 

type StringBuilder struct {
	*array.StringBuilder
	*array.String

	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func NewStringBuilder 

func NewStringBuilder() *StringBuilder

func NewStringBuilderFromArray 

func NewStringBuilderFromArray(array *array.String) *StringBuilder

func (*StringBuilder) Build 

func (arr *StringBuilder) Build(client *client.IPCClient) (err error)

func (*StringBuilder) Seal 

func (arr *StringBuilder) Seal(c *client.IPCClient) (types.ObjectID, error)

type Table 

type Table struct {
	client.Object
	arrow.Table
}

func (*Table) Construct 

func (r *Table) Construct(c *client.IPCClient, meta *client.ObjectMeta) (err error)

type TableBuilder 

type TableBuilder struct {
	Schema        *arrow.Schema
	SchemaBuilder *SchemaBuilder
	NumColumns    uint64
	NumRows       uint64

	Records []arrow.Record
	Batches []types.ObjectID
}

func NewTableBuilder 

func NewTableBuilder(table arrow.Table) *TableBuilder

func NewTableBuilderFromBatches 

func NewTableBuilderFromBatches(schema *arrow.Schema, records []arrow.Record) *TableBuilder

func (*TableBuilder) Build 

func (r *TableBuilder) Build(c *client.IPCClient) error

func (*TableBuilder) Seal 

func (r *TableBuilder) Seal(c *client.IPCClient) (types.ObjectID, error)

type Uint32Array 

type Uint32Array struct {
	client.Object
	*array.Uint32
	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func (*Uint32Array) Construct 

func (arr *Uint32Array) Construct(c *client.IPCClient, meta *client.ObjectMeta) (err error)

func (*Uint32Array) GetArray 

func (arr *Uint32Array) GetArray() arrow.Array

type Uint32Builder 

type Uint32Builder struct {
	*array.Uint32Builder
	*array.Uint32

	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func NewUint32BuilderFromArray 

func NewUint32BuilderFromArray(array *array.Uint32) *Uint32Builder

func (*Uint32Builder) Build 

func (arr *Uint32Builder) Build(client *client.IPCClient) (err error)

func (*Uint32Builder) Seal 

func (arr *Uint32Builder) Seal(c *client.IPCClient) (types.ObjectID, error)

type Uint64Array 

type Uint64Array struct {
	client.Object
	*array.Uint64
	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func (*Uint64Array) Construct 

func (arr *Uint64Array) Construct(c *client.IPCClient, meta *client.ObjectMeta) (err error)

func (*Uint64Array) GetArray 

func (arr *Uint64Array) GetArray() arrow.Array

type Uint64Builder 

type Uint64Builder struct {
	*array.Uint64Builder
	*array.Uint64

	Length    uint64
	NullCount uint64
	Offset    uint64
	// contains filtered or unexported fields
}

func NewUint64BuilderFromArray 

func NewUint64BuilderFromArray(array *array.Uint64) *Uint64Builder

func (*Uint64Builder) Build 

func (arr *Uint64Builder) Build(client *client.IPCClient) (err error)

func (*Uint64Builder) Seal 

func (arr *Uint64Builder) Seal(c *client.IPCClient) (types.ObjectID, error)

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.