iterator

package
v0.0.0-...-77951e0 Latest Latest
Warning

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

 Go to latest Published: Jul 7, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package iterator provides iterators for chunks and values.

Since Arrow can store chunks larger than the max int64 (9223372036854775807) due to how it store chunks, it's best to use iterators to iterate over chunks and their values.

There are generic ChunkIterator and ValueIterator implementations as well as specific generated Arrow types for each of them, i.e. Float64ChunkIterator and Float64ValueIterator.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BooleanValueIterator 

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

BooleanValueIterator is an iterator for reading an Arrow Column value by value.

func NewBooleanValueIterator 

func NewBooleanValueIterator(col *array.Column) *BooleanValueIterator

NewBooleanValueIterator creates a new BooleanValueIterator for reading an Arrow Column.

func (*BooleanValueIterator) Next 

func (vr *BooleanValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*BooleanValueIterator) Release 

func (vr *BooleanValueIterator) Release()

Release removes a reference to the BooleanValueIterator

func (*BooleanValueIterator) Retain 

func (vr *BooleanValueIterator) Retain()

Retain keeps a reference to the BooleanValueIterator

func (*BooleanValueIterator) Value 

func (vr *BooleanValueIterator) Value() (bool, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*BooleanValueIterator) ValueInterface 

func (vr *BooleanValueIterator) ValueInterface() interface{}

ValueInterface returns the value as an interface{}.

func (*BooleanValueIterator) ValuePointer 

func (vr *BooleanValueIterator) ValuePointer() *bool

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type ChunkIterator 

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

ChunkIterator is a generic iterator for reading an Arrow Column chunk by chunk.

func NewChunkIterator 

func NewChunkIterator(col *array.Column) *ChunkIterator

NewChunkIterator creates a new ChunkIterator for reading an Arrow Column.

func (*ChunkIterator) Chunk 

func (cr *ChunkIterator) Chunk() array.Interface

Chunk will return the current chunk that the iterator is on.

func (*ChunkIterator) Next 

func (cr *ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*ChunkIterator) Release 

func (cr *ChunkIterator) Release()

Release removes a reference to the ChunkIterator

func (*ChunkIterator) Retain 

func (cr *ChunkIterator) Retain()

Retain keeps a reference to the ChunkIterator

type Date32ChunkIterator 

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

Date32ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewDate32ChunkIterator 

func NewDate32ChunkIterator(col *array.Column) *Date32ChunkIterator

NewDate32ChunkIterator creates a new Date32ChunkIterator for reading an Arrow Column.

func (*Date32ChunkIterator) Chunk 

func (cr *Date32ChunkIterator) Chunk() *array.Date32

Chunk will return the current chunk that the iterator is on.

func (*Date32ChunkIterator) ChunkValues 

func (cr *Date32ChunkIterator) ChunkValues() []arrow.Date32

ChunkValues returns the underlying []arrow.Date32 chunk values. Keep in mind the []arrow.Date32 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Date32ChunkIterator) Next 

func (cr *Date32ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Date32ChunkIterator) Release 

func (cr *Date32ChunkIterator) Release()

Release removes a reference to the Date32ChunkIterator

func (*Date32ChunkIterator) Retain 

func (cr *Date32ChunkIterator) Retain()

Retain keeps a reference to the Date32ChunkIterator

type Date32ValueIterator 

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

Date32ValueIterator is an iterator for reading an Arrow Column value by value.

func NewDate32ValueIterator 

func NewDate32ValueIterator(col *array.Column) *Date32ValueIterator

NewDate32ValueIterator creates a new Date32ValueIterator for reading an Arrow Column.

func (*Date32ValueIterator) Next 

func (vr *Date32ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Date32ValueIterator) Release 

func (vr *Date32ValueIterator) Release()

Release removes a reference to the Date32ValueIterator.

func (*Date32ValueIterator) Retain 

func (vr *Date32ValueIterator) Retain()

Retain keeps a reference to the Date32ValueIterator.

func (*Date32ValueIterator) Value 

func (vr *Date32ValueIterator) Value() (arrow.Date32, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Date32ValueIterator) ValueInterface 

func (vr *Date32ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Date32ValueIterator) ValuePointer 

func (vr *Date32ValueIterator) ValuePointer() *arrow.Date32

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Date64ChunkIterator 

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

Date64ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewDate64ChunkIterator 

func NewDate64ChunkIterator(col *array.Column) *Date64ChunkIterator

NewDate64ChunkIterator creates a new Date64ChunkIterator for reading an Arrow Column.

func (*Date64ChunkIterator) Chunk 

func (cr *Date64ChunkIterator) Chunk() *array.Date64

Chunk will return the current chunk that the iterator is on.

func (*Date64ChunkIterator) ChunkValues 

func (cr *Date64ChunkIterator) ChunkValues() []arrow.Date64

ChunkValues returns the underlying []arrow.Date64 chunk values. Keep in mind the []arrow.Date64 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Date64ChunkIterator) Next 

func (cr *Date64ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Date64ChunkIterator) Release 

func (cr *Date64ChunkIterator) Release()

Release removes a reference to the Date64ChunkIterator

func (*Date64ChunkIterator) Retain 

func (cr *Date64ChunkIterator) Retain()

Retain keeps a reference to the Date64ChunkIterator

type Date64ValueIterator 

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

Date64ValueIterator is an iterator for reading an Arrow Column value by value.

func NewDate64ValueIterator 

func NewDate64ValueIterator(col *array.Column) *Date64ValueIterator

NewDate64ValueIterator creates a new Date64ValueIterator for reading an Arrow Column.

func (*Date64ValueIterator) Next 

func (vr *Date64ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Date64ValueIterator) Release 

func (vr *Date64ValueIterator) Release()

Release removes a reference to the Date64ValueIterator.

func (*Date64ValueIterator) Retain 

func (vr *Date64ValueIterator) Retain()

Retain keeps a reference to the Date64ValueIterator.

func (*Date64ValueIterator) Value 

func (vr *Date64ValueIterator) Value() (arrow.Date64, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Date64ValueIterator) ValueInterface 

func (vr *Date64ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Date64ValueIterator) ValuePointer 

func (vr *Date64ValueIterator) ValuePointer() *arrow.Date64

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Float32ChunkIterator 

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

Float32ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewFloat32ChunkIterator 

func NewFloat32ChunkIterator(col *array.Column) *Float32ChunkIterator

NewFloat32ChunkIterator creates a new Float32ChunkIterator for reading an Arrow Column.

func (*Float32ChunkIterator) Chunk 

func (cr *Float32ChunkIterator) Chunk() *array.Float32

Chunk will return the current chunk that the iterator is on.

func (*Float32ChunkIterator) ChunkValues 

func (cr *Float32ChunkIterator) ChunkValues() []float32

ChunkValues returns the underlying []float32 chunk values. Keep in mind the []float32 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Float32ChunkIterator) Next 

func (cr *Float32ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Float32ChunkIterator) Release 

func (cr *Float32ChunkIterator) Release()

Release removes a reference to the Float32ChunkIterator

func (*Float32ChunkIterator) Retain 

func (cr *Float32ChunkIterator) Retain()

Retain keeps a reference to the Float32ChunkIterator

type Float32ValueIterator 

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

Float32ValueIterator is an iterator for reading an Arrow Column value by value.

func NewFloat32ValueIterator 

func NewFloat32ValueIterator(col *array.Column) *Float32ValueIterator

NewFloat32ValueIterator creates a new Float32ValueIterator for reading an Arrow Column.

func (*Float32ValueIterator) Next 

func (vr *Float32ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Float32ValueIterator) Release 

func (vr *Float32ValueIterator) Release()

Release removes a reference to the Float32ValueIterator.

func (*Float32ValueIterator) Retain 

func (vr *Float32ValueIterator) Retain()

Retain keeps a reference to the Float32ValueIterator.

func (*Float32ValueIterator) Value 

func (vr *Float32ValueIterator) Value() (float32, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Float32ValueIterator) ValueInterface 

func (vr *Float32ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Float32ValueIterator) ValuePointer 

func (vr *Float32ValueIterator) ValuePointer() *float32

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Float64ChunkIterator 

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

Float64ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewFloat64ChunkIterator 

func NewFloat64ChunkIterator(col *array.Column) *Float64ChunkIterator

NewFloat64ChunkIterator creates a new Float64ChunkIterator for reading an Arrow Column.

func (*Float64ChunkIterator) Chunk 

func (cr *Float64ChunkIterator) Chunk() *array.Float64

Chunk will return the current chunk that the iterator is on.

func (*Float64ChunkIterator) ChunkValues 

func (cr *Float64ChunkIterator) ChunkValues() []float64

ChunkValues returns the underlying []float64 chunk values. Keep in mind the []float64 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Float64ChunkIterator) Next 

func (cr *Float64ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Float64ChunkIterator) Release 

func (cr *Float64ChunkIterator) Release()

Release removes a reference to the Float64ChunkIterator

func (*Float64ChunkIterator) Retain 

func (cr *Float64ChunkIterator) Retain()

Retain keeps a reference to the Float64ChunkIterator

type Float64ValueIterator 

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

Float64ValueIterator is an iterator for reading an Arrow Column value by value.

func NewFloat64ValueIterator 

func NewFloat64ValueIterator(col *array.Column) *Float64ValueIterator

NewFloat64ValueIterator creates a new Float64ValueIterator for reading an Arrow Column.

func (*Float64ValueIterator) Next 

func (vr *Float64ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Float64ValueIterator) Release 

func (vr *Float64ValueIterator) Release()

Release removes a reference to the Float64ValueIterator.

func (*Float64ValueIterator) Retain 

func (vr *Float64ValueIterator) Retain()

Retain keeps a reference to the Float64ValueIterator.

func (*Float64ValueIterator) Value 

func (vr *Float64ValueIterator) Value() (float64, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Float64ValueIterator) ValueInterface 

func (vr *Float64ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Float64ValueIterator) ValuePointer 

func (vr *Float64ValueIterator) ValuePointer() *float64

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Int16ChunkIterator 

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

Int16ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewInt16ChunkIterator 

func NewInt16ChunkIterator(col *array.Column) *Int16ChunkIterator

NewInt16ChunkIterator creates a new Int16ChunkIterator for reading an Arrow Column.

func (*Int16ChunkIterator) Chunk 

func (cr *Int16ChunkIterator) Chunk() *array.Int16

Chunk will return the current chunk that the iterator is on.

func (*Int16ChunkIterator) ChunkValues 

func (cr *Int16ChunkIterator) ChunkValues() []int16

ChunkValues returns the underlying []int16 chunk values. Keep in mind the []int16 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Int16ChunkIterator) Next 

func (cr *Int16ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Int16ChunkIterator) Release 

func (cr *Int16ChunkIterator) Release()

Release removes a reference to the Int16ChunkIterator

func (*Int16ChunkIterator) Retain 

func (cr *Int16ChunkIterator) Retain()

Retain keeps a reference to the Int16ChunkIterator

type Int16ValueIterator 

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

Int16ValueIterator is an iterator for reading an Arrow Column value by value.

func NewInt16ValueIterator 

func NewInt16ValueIterator(col *array.Column) *Int16ValueIterator

NewInt16ValueIterator creates a new Int16ValueIterator for reading an Arrow Column.

func (*Int16ValueIterator) Next 

func (vr *Int16ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Int16ValueIterator) Release 

func (vr *Int16ValueIterator) Release()

Release removes a reference to the Int16ValueIterator.

func (*Int16ValueIterator) Retain 

func (vr *Int16ValueIterator) Retain()

Retain keeps a reference to the Int16ValueIterator.

func (*Int16ValueIterator) Value 

func (vr *Int16ValueIterator) Value() (int16, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Int16ValueIterator) ValueInterface 

func (vr *Int16ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Int16ValueIterator) ValuePointer 

func (vr *Int16ValueIterator) ValuePointer() *int16

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Int32ChunkIterator 

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

Int32ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewInt32ChunkIterator 

func NewInt32ChunkIterator(col *array.Column) *Int32ChunkIterator

NewInt32ChunkIterator creates a new Int32ChunkIterator for reading an Arrow Column.

func (*Int32ChunkIterator) Chunk 

func (cr *Int32ChunkIterator) Chunk() *array.Int32

Chunk will return the current chunk that the iterator is on.

func (*Int32ChunkIterator) ChunkValues 

func (cr *Int32ChunkIterator) ChunkValues() []int32

ChunkValues returns the underlying []int32 chunk values. Keep in mind the []int32 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Int32ChunkIterator) Next 

func (cr *Int32ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Int32ChunkIterator) Release 

func (cr *Int32ChunkIterator) Release()

Release removes a reference to the Int32ChunkIterator

func (*Int32ChunkIterator) Retain 

func (cr *Int32ChunkIterator) Retain()

Retain keeps a reference to the Int32ChunkIterator

type Int32ValueIterator 

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

Int32ValueIterator is an iterator for reading an Arrow Column value by value.

func NewInt32ValueIterator 

func NewInt32ValueIterator(col *array.Column) *Int32ValueIterator

NewInt32ValueIterator creates a new Int32ValueIterator for reading an Arrow Column.

func (*Int32ValueIterator) Next 

func (vr *Int32ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Int32ValueIterator) Release 

func (vr *Int32ValueIterator) Release()

Release removes a reference to the Int32ValueIterator.

func (*Int32ValueIterator) Retain 

func (vr *Int32ValueIterator) Retain()

Retain keeps a reference to the Int32ValueIterator.

func (*Int32ValueIterator) Value 

func (vr *Int32ValueIterator) Value() (int32, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Int32ValueIterator) ValueInterface 

func (vr *Int32ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Int32ValueIterator) ValuePointer 

func (vr *Int32ValueIterator) ValuePointer() *int32

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Int64ChunkIterator 

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

Int64ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewInt64ChunkIterator 

func NewInt64ChunkIterator(col *array.Column) *Int64ChunkIterator

NewInt64ChunkIterator creates a new Int64ChunkIterator for reading an Arrow Column.

func (*Int64ChunkIterator) Chunk 

func (cr *Int64ChunkIterator) Chunk() *array.Int64

Chunk will return the current chunk that the iterator is on.

func (*Int64ChunkIterator) ChunkValues 

func (cr *Int64ChunkIterator) ChunkValues() []int64

ChunkValues returns the underlying []int64 chunk values. Keep in mind the []int64 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Int64ChunkIterator) Next 

func (cr *Int64ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Int64ChunkIterator) Release 

func (cr *Int64ChunkIterator) Release()

Release removes a reference to the Int64ChunkIterator

func (*Int64ChunkIterator) Retain 

func (cr *Int64ChunkIterator) Retain()

Retain keeps a reference to the Int64ChunkIterator

type Int64ValueIterator 

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

Int64ValueIterator is an iterator for reading an Arrow Column value by value.

func NewInt64ValueIterator 

func NewInt64ValueIterator(col *array.Column) *Int64ValueIterator

NewInt64ValueIterator creates a new Int64ValueIterator for reading an Arrow Column.

func (*Int64ValueIterator) Next 

func (vr *Int64ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Int64ValueIterator) Release 

func (vr *Int64ValueIterator) Release()

Release removes a reference to the Int64ValueIterator.

func (*Int64ValueIterator) Retain 

func (vr *Int64ValueIterator) Retain()

Retain keeps a reference to the Int64ValueIterator.

func (*Int64ValueIterator) Value 

func (vr *Int64ValueIterator) Value() (int64, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Int64ValueIterator) ValueInterface 

func (vr *Int64ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Int64ValueIterator) ValuePointer 

func (vr *Int64ValueIterator) ValuePointer() *int64

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Int8ChunkIterator 

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

Int8ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewInt8ChunkIterator 

func NewInt8ChunkIterator(col *array.Column) *Int8ChunkIterator

NewInt8ChunkIterator creates a new Int8ChunkIterator for reading an Arrow Column.

func (*Int8ChunkIterator) Chunk 

func (cr *Int8ChunkIterator) Chunk() *array.Int8

Chunk will return the current chunk that the iterator is on.

func (*Int8ChunkIterator) ChunkValues 

func (cr *Int8ChunkIterator) ChunkValues() []int8

ChunkValues returns the underlying []int8 chunk values. Keep in mind the []int8 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Int8ChunkIterator) Next 

func (cr *Int8ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Int8ChunkIterator) Release 

func (cr *Int8ChunkIterator) Release()

Release removes a reference to the Int8ChunkIterator

func (*Int8ChunkIterator) Retain 

func (cr *Int8ChunkIterator) Retain()

Retain keeps a reference to the Int8ChunkIterator

type Int8ValueIterator 

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

Int8ValueIterator is an iterator for reading an Arrow Column value by value.

func NewInt8ValueIterator 

func NewInt8ValueIterator(col *array.Column) *Int8ValueIterator

NewInt8ValueIterator creates a new Int8ValueIterator for reading an Arrow Column.

func (*Int8ValueIterator) Next 

func (vr *Int8ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Int8ValueIterator) Release 

func (vr *Int8ValueIterator) Release()

Release removes a reference to the Int8ValueIterator.

func (*Int8ValueIterator) Retain 

func (vr *Int8ValueIterator) Retain()

Retain keeps a reference to the Int8ValueIterator.

func (*Int8ValueIterator) Value 

func (vr *Int8ValueIterator) Value() (int8, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Int8ValueIterator) ValueInterface 

func (vr *Int8ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Int8ValueIterator) ValuePointer 

func (vr *Int8ValueIterator) ValuePointer() *int8

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type StepIterator 

type StepIterator interface {
	Values() *StepValue
	Next() bool
	Retain()
	Release()
}

StepIterator iterates over multiple iterators in step.

func NewStepIterator 

func NewStepIterator(dtypes []arrow.DataType, iterators ...ValueIterator) StepIterator

NewStepIterator creates a new StepIterator given a bunch of ValueIterators.

func NewStepIteratorForColumns 

func NewStepIteratorForColumns(cols []array.Column) StepIterator

NewStepIteratorForColumns creates a new StepIterator given a slice of columns.

type StepValue 

type StepValue struct {
	Values []interface{}
	Exists []bool
	Dtypes []arrow.DataType
}

StepValue holds the value for a given step.

func (StepValue) Value 

func (sv StepValue) Value(i int) (interface{}, arrow.DataType)

Value returns the value at index i and the data type for that value.

type StringValueIterator 

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

StringValueIterator is an iterator for reading an Arrow Column value by value for variable-length UTF-8 strings.

func NewStringValueIterator 

func NewStringValueIterator(col *array.Column) *StringValueIterator

NewStringValueIterator creates a new StringValueIterator for reading an Arrow Column.

func (*StringValueIterator) Next 

func (vr *StringValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*StringValueIterator) Release 

func (vr *StringValueIterator) Release()

Release removes a reference to the StringValueIterator

func (*StringValueIterator) Retain 

func (vr *StringValueIterator) Retain()

Retain keeps a reference to the StringValueIterator

func (*StringValueIterator) Value 

func (vr *StringValueIterator) Value() (string, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*StringValueIterator) ValueInterface 

func (vr *StringValueIterator) ValueInterface() interface{}

ValueInterface returns the value as an interface{}.

func (*StringValueIterator) ValuePointer 

func (vr *StringValueIterator) ValuePointer() *string

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Time32ChunkIterator 

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

Time32ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewTime32ChunkIterator 

func NewTime32ChunkIterator(col *array.Column) *Time32ChunkIterator

NewTime32ChunkIterator creates a new Time32ChunkIterator for reading an Arrow Column.

func (*Time32ChunkIterator) Chunk 

func (cr *Time32ChunkIterator) Chunk() *array.Time32

Chunk will return the current chunk that the iterator is on.

func (*Time32ChunkIterator) ChunkValues 

func (cr *Time32ChunkIterator) ChunkValues() []arrow.Time32

ChunkValues returns the underlying []arrow.Time32 chunk values. Keep in mind the []arrow.Time32 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Time32ChunkIterator) Next 

func (cr *Time32ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Time32ChunkIterator) Release 

func (cr *Time32ChunkIterator) Release()

Release removes a reference to the Time32ChunkIterator

func (*Time32ChunkIterator) Retain 

func (cr *Time32ChunkIterator) Retain()

Retain keeps a reference to the Time32ChunkIterator

type Time32ValueIterator 

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

Time32ValueIterator is an iterator for reading an Arrow Column value by value.

func NewTime32ValueIterator 

func NewTime32ValueIterator(col *array.Column) *Time32ValueIterator

NewTime32ValueIterator creates a new Time32ValueIterator for reading an Arrow Column.

func (*Time32ValueIterator) Next 

func (vr *Time32ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Time32ValueIterator) Release 

func (vr *Time32ValueIterator) Release()

Release removes a reference to the Time32ValueIterator.

func (*Time32ValueIterator) Retain 

func (vr *Time32ValueIterator) Retain()

Retain keeps a reference to the Time32ValueIterator.

func (*Time32ValueIterator) Value 

func (vr *Time32ValueIterator) Value() (arrow.Time32, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Time32ValueIterator) ValueInterface 

func (vr *Time32ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Time32ValueIterator) ValuePointer 

func (vr *Time32ValueIterator) ValuePointer() *arrow.Time32

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Time64ChunkIterator 

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

Time64ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewTime64ChunkIterator 

func NewTime64ChunkIterator(col *array.Column) *Time64ChunkIterator

NewTime64ChunkIterator creates a new Time64ChunkIterator for reading an Arrow Column.

func (*Time64ChunkIterator) Chunk 

func (cr *Time64ChunkIterator) Chunk() *array.Time64

Chunk will return the current chunk that the iterator is on.

func (*Time64ChunkIterator) ChunkValues 

func (cr *Time64ChunkIterator) ChunkValues() []arrow.Time64

ChunkValues returns the underlying []arrow.Time64 chunk values. Keep in mind the []arrow.Time64 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Time64ChunkIterator) Next 

func (cr *Time64ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Time64ChunkIterator) Release 

func (cr *Time64ChunkIterator) Release()

Release removes a reference to the Time64ChunkIterator

func (*Time64ChunkIterator) Retain 

func (cr *Time64ChunkIterator) Retain()

Retain keeps a reference to the Time64ChunkIterator

type Time64ValueIterator 

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

Time64ValueIterator is an iterator for reading an Arrow Column value by value.

func NewTime64ValueIterator 

func NewTime64ValueIterator(col *array.Column) *Time64ValueIterator

NewTime64ValueIterator creates a new Time64ValueIterator for reading an Arrow Column.

func (*Time64ValueIterator) Next 

func (vr *Time64ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Time64ValueIterator) Release 

func (vr *Time64ValueIterator) Release()

Release removes a reference to the Time64ValueIterator.

func (*Time64ValueIterator) Retain 

func (vr *Time64ValueIterator) Retain()

Retain keeps a reference to the Time64ValueIterator.

func (*Time64ValueIterator) Value 

func (vr *Time64ValueIterator) Value() (arrow.Time64, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Time64ValueIterator) ValueInterface 

func (vr *Time64ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Time64ValueIterator) ValuePointer 

func (vr *Time64ValueIterator) ValuePointer() *arrow.Time64

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type TimestampChunkIterator 

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

TimestampChunkIterator is an iterator for reading an Arrow Column value by value.

func NewTimestampChunkIterator 

func NewTimestampChunkIterator(col *array.Column) *TimestampChunkIterator

NewTimestampChunkIterator creates a new TimestampChunkIterator for reading an Arrow Column.

func (*TimestampChunkIterator) Chunk 

func (cr *TimestampChunkIterator) Chunk() *array.Timestamp

Chunk will return the current chunk that the iterator is on.

func (*TimestampChunkIterator) ChunkValues 

func (cr *TimestampChunkIterator) ChunkValues() []arrow.Timestamp

ChunkValues returns the underlying []arrow.Timestamp chunk values. Keep in mind the []arrow.Timestamp type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*TimestampChunkIterator) Next 

func (cr *TimestampChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*TimestampChunkIterator) Release 

func (cr *TimestampChunkIterator) Release()

Release removes a reference to the TimestampChunkIterator

func (*TimestampChunkIterator) Retain 

func (cr *TimestampChunkIterator) Retain()

Retain keeps a reference to the TimestampChunkIterator

type TimestampValueIterator 

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

TimestampValueIterator is an iterator for reading an Arrow Column value by value.

func NewTimestampValueIterator 

func NewTimestampValueIterator(col *array.Column) *TimestampValueIterator

NewTimestampValueIterator creates a new TimestampValueIterator for reading an Arrow Column.

func (*TimestampValueIterator) Next 

func (vr *TimestampValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*TimestampValueIterator) Release 

func (vr *TimestampValueIterator) Release()

Release removes a reference to the TimestampValueIterator.

func (*TimestampValueIterator) Retain 

func (vr *TimestampValueIterator) Retain()

Retain keeps a reference to the TimestampValueIterator.

func (*TimestampValueIterator) Value 

func (vr *TimestampValueIterator) Value() (arrow.Timestamp, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*TimestampValueIterator) ValueInterface 

func (vr *TimestampValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*TimestampValueIterator) ValuePointer 

func (vr *TimestampValueIterator) ValuePointer() *arrow.Timestamp

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Uint16ChunkIterator 

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

Uint16ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewUint16ChunkIterator 

func NewUint16ChunkIterator(col *array.Column) *Uint16ChunkIterator

NewUint16ChunkIterator creates a new Uint16ChunkIterator for reading an Arrow Column.

func (*Uint16ChunkIterator) Chunk 

func (cr *Uint16ChunkIterator) Chunk() *array.Uint16

Chunk will return the current chunk that the iterator is on.

func (*Uint16ChunkIterator) ChunkValues 

func (cr *Uint16ChunkIterator) ChunkValues() []uint16

ChunkValues returns the underlying []uint16 chunk values. Keep in mind the []uint16 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Uint16ChunkIterator) Next 

func (cr *Uint16ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Uint16ChunkIterator) Release 

func (cr *Uint16ChunkIterator) Release()

Release removes a reference to the Uint16ChunkIterator

func (*Uint16ChunkIterator) Retain 

func (cr *Uint16ChunkIterator) Retain()

Retain keeps a reference to the Uint16ChunkIterator

type Uint16ValueIterator 

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

Uint16ValueIterator is an iterator for reading an Arrow Column value by value.

func NewUint16ValueIterator 

func NewUint16ValueIterator(col *array.Column) *Uint16ValueIterator

NewUint16ValueIterator creates a new Uint16ValueIterator for reading an Arrow Column.

func (*Uint16ValueIterator) Next 

func (vr *Uint16ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Uint16ValueIterator) Release 

func (vr *Uint16ValueIterator) Release()

Release removes a reference to the Uint16ValueIterator.

func (*Uint16ValueIterator) Retain 

func (vr *Uint16ValueIterator) Retain()

Retain keeps a reference to the Uint16ValueIterator.

func (*Uint16ValueIterator) Value 

func (vr *Uint16ValueIterator) Value() (uint16, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Uint16ValueIterator) ValueInterface 

func (vr *Uint16ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Uint16ValueIterator) ValuePointer 

func (vr *Uint16ValueIterator) ValuePointer() *uint16

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Uint32ChunkIterator 

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

Uint32ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewUint32ChunkIterator 

func NewUint32ChunkIterator(col *array.Column) *Uint32ChunkIterator

NewUint32ChunkIterator creates a new Uint32ChunkIterator for reading an Arrow Column.

func (*Uint32ChunkIterator) Chunk 

func (cr *Uint32ChunkIterator) Chunk() *array.Uint32

Chunk will return the current chunk that the iterator is on.

func (*Uint32ChunkIterator) ChunkValues 

func (cr *Uint32ChunkIterator) ChunkValues() []uint32

ChunkValues returns the underlying []uint32 chunk values. Keep in mind the []uint32 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Uint32ChunkIterator) Next 

func (cr *Uint32ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Uint32ChunkIterator) Release 

func (cr *Uint32ChunkIterator) Release()

Release removes a reference to the Uint32ChunkIterator

func (*Uint32ChunkIterator) Retain 

func (cr *Uint32ChunkIterator) Retain()

Retain keeps a reference to the Uint32ChunkIterator

type Uint32ValueIterator 

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

Uint32ValueIterator is an iterator for reading an Arrow Column value by value.

func NewUint32ValueIterator 

func NewUint32ValueIterator(col *array.Column) *Uint32ValueIterator

NewUint32ValueIterator creates a new Uint32ValueIterator for reading an Arrow Column.

func (*Uint32ValueIterator) Next 

func (vr *Uint32ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Uint32ValueIterator) Release 

func (vr *Uint32ValueIterator) Release()

Release removes a reference to the Uint32ValueIterator.

func (*Uint32ValueIterator) Retain 

func (vr *Uint32ValueIterator) Retain()

Retain keeps a reference to the Uint32ValueIterator.

func (*Uint32ValueIterator) Value 

func (vr *Uint32ValueIterator) Value() (uint32, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Uint32ValueIterator) ValueInterface 

func (vr *Uint32ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Uint32ValueIterator) ValuePointer 

func (vr *Uint32ValueIterator) ValuePointer() *uint32

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Uint64ChunkIterator 

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

Uint64ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewUint64ChunkIterator 

func NewUint64ChunkIterator(col *array.Column) *Uint64ChunkIterator

NewUint64ChunkIterator creates a new Uint64ChunkIterator for reading an Arrow Column.

func (*Uint64ChunkIterator) Chunk 

func (cr *Uint64ChunkIterator) Chunk() *array.Uint64

Chunk will return the current chunk that the iterator is on.

func (*Uint64ChunkIterator) ChunkValues 

func (cr *Uint64ChunkIterator) ChunkValues() []uint64

ChunkValues returns the underlying []uint64 chunk values. Keep in mind the []uint64 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Uint64ChunkIterator) Next 

func (cr *Uint64ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Uint64ChunkIterator) Release 

func (cr *Uint64ChunkIterator) Release()

Release removes a reference to the Uint64ChunkIterator

func (*Uint64ChunkIterator) Retain 

func (cr *Uint64ChunkIterator) Retain()

Retain keeps a reference to the Uint64ChunkIterator

type Uint64ValueIterator 

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

Uint64ValueIterator is an iterator for reading an Arrow Column value by value.

func NewUint64ValueIterator 

func NewUint64ValueIterator(col *array.Column) *Uint64ValueIterator

NewUint64ValueIterator creates a new Uint64ValueIterator for reading an Arrow Column.

func (*Uint64ValueIterator) Next 

func (vr *Uint64ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Uint64ValueIterator) Release 

func (vr *Uint64ValueIterator) Release()

Release removes a reference to the Uint64ValueIterator.

func (*Uint64ValueIterator) Retain 

func (vr *Uint64ValueIterator) Retain()

Retain keeps a reference to the Uint64ValueIterator.

func (*Uint64ValueIterator) Value 

func (vr *Uint64ValueIterator) Value() (uint64, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Uint64ValueIterator) ValueInterface 

func (vr *Uint64ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Uint64ValueIterator) ValuePointer 

func (vr *Uint64ValueIterator) ValuePointer() *uint64

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type Uint8ChunkIterator 

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

Uint8ChunkIterator is an iterator for reading an Arrow Column value by value.

func NewUint8ChunkIterator 

func NewUint8ChunkIterator(col *array.Column) *Uint8ChunkIterator

NewUint8ChunkIterator creates a new Uint8ChunkIterator for reading an Arrow Column.

func (*Uint8ChunkIterator) Chunk 

func (cr *Uint8ChunkIterator) Chunk() *array.Uint8

Chunk will return the current chunk that the iterator is on.

func (*Uint8ChunkIterator) ChunkValues 

func (cr *Uint8ChunkIterator) ChunkValues() []uint8

ChunkValues returns the underlying []uint8 chunk values. Keep in mind the []uint8 type might not be able to account for nil values. You must check for those explicitly via the chunk.

func (*Uint8ChunkIterator) Next 

func (cr *Uint8ChunkIterator) Next() bool

Next moves the iterator to the next chunk. This will return false when there are no more chunks.

func (*Uint8ChunkIterator) Release 

func (cr *Uint8ChunkIterator) Release()

Release removes a reference to the Uint8ChunkIterator

func (*Uint8ChunkIterator) Retain 

func (cr *Uint8ChunkIterator) Retain()

Retain keeps a reference to the Uint8ChunkIterator

type Uint8ValueIterator 

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

Uint8ValueIterator is an iterator for reading an Arrow Column value by value.

func NewUint8ValueIterator 

func NewUint8ValueIterator(col *array.Column) *Uint8ValueIterator

NewUint8ValueIterator creates a new Uint8ValueIterator for reading an Arrow Column.

func (*Uint8ValueIterator) Next 

func (vr *Uint8ValueIterator) Next() bool

Next moves the iterator to the next value. This will return false when there are no more values.

func (*Uint8ValueIterator) Release 

func (vr *Uint8ValueIterator) Release()

Release removes a reference to the Uint8ValueIterator.

func (*Uint8ValueIterator) Retain 

func (vr *Uint8ValueIterator) Retain()

Retain keeps a reference to the Uint8ValueIterator.

func (*Uint8ValueIterator) Value 

func (vr *Uint8ValueIterator) Value() (uint8, bool)

Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.

func (*Uint8ValueIterator) ValueInterface 

func (vr *Uint8ValueIterator) ValueInterface() interface{}

ValueInterface returns the current value as an interface{}.

func (*Uint8ValueIterator) ValuePointer 

func (vr *Uint8ValueIterator) ValuePointer() *uint8

ValuePointer will return a pointer to the current value that the iterator is on. It will return nil if the value is actually null.

type ValueIterator 

type ValueIterator interface {
	// ValueInterface returns the current value as an interface{}.
	ValueInterface() interface{}

	// Next moves the iterator to the next value. This will return false when there are no more values.
	Next() bool

	// Retain keeps a reference to the ValueIterator.
	Retain()

	// Release removes a reference to the ValueIterator.
	Release()
}

ValueIterator is a generic iterator for scanning over values.

func NewValueIterator 

func NewValueIterator(column *array.Column) ValueIterator

NewValueIterator creates a new generic ValueIterator.

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.