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 stores 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 ¶
- type BooleanValueIterator
- func (vr *BooleanValueIterator) DataType() arrow.DataType
- func (vr *BooleanValueIterator) Next() bool
- func (vr *BooleanValueIterator) Release()
- func (vr *BooleanValueIterator) Retain()
- func (vr *BooleanValueIterator) Value() (bool, bool)
- func (vr *BooleanValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *BooleanValueIterator) ValueInterface() interface{}
- func (vr *BooleanValueIterator) ValuePointer() *bool
- type ChunkIterator
- type Date32ChunkIterator
- type Date32ValueIterator
- func (vr *Date32ValueIterator) DataType() arrow.DataType
- func (vr *Date32ValueIterator) Next() bool
- func (vr *Date32ValueIterator) Release()
- func (vr *Date32ValueIterator) Retain()
- func (vr *Date32ValueIterator) Value() (arrow.Date32, bool)
- func (vr *Date32ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Date32ValueIterator) ValueInterface() interface{}
- func (vr *Date32ValueIterator) ValuePointer() *arrow.Date32
- type Date64ChunkIterator
- type Date64ValueIterator
- func (vr *Date64ValueIterator) DataType() arrow.DataType
- func (vr *Date64ValueIterator) Next() bool
- func (vr *Date64ValueIterator) Release()
- func (vr *Date64ValueIterator) Retain()
- func (vr *Date64ValueIterator) Value() (arrow.Date64, bool)
- func (vr *Date64ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Date64ValueIterator) ValueInterface() interface{}
- func (vr *Date64ValueIterator) ValuePointer() *arrow.Date64
- type DayTimeIntervalChunkIterator
- type DayTimeIntervalValueIterator
- func (vr *DayTimeIntervalValueIterator) DataType() arrow.DataType
- func (vr *DayTimeIntervalValueIterator) Next() bool
- func (vr *DayTimeIntervalValueIterator) Release()
- func (vr *DayTimeIntervalValueIterator) Retain()
- func (vr *DayTimeIntervalValueIterator) Value() (arrow.DayTimeInterval, bool)
- func (vr *DayTimeIntervalValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *DayTimeIntervalValueIterator) ValueInterface() interface{}
- func (vr *DayTimeIntervalValueIterator) ValuePointer() *arrow.DayTimeInterval
- type Decimal128ChunkIterator
- type Decimal128ValueIterator
- func (vr *Decimal128ValueIterator) DataType() arrow.DataType
- func (vr *Decimal128ValueIterator) Next() bool
- func (vr *Decimal128ValueIterator) Release()
- func (vr *Decimal128ValueIterator) Retain()
- func (vr *Decimal128ValueIterator) Value() (decimal128.Num, bool)
- func (vr *Decimal128ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Decimal128ValueIterator) ValueInterface() interface{}
- func (vr *Decimal128ValueIterator) ValuePointer() *decimal128.Num
- type DurationChunkIterator
- type DurationValueIterator
- func (vr *DurationValueIterator) DataType() arrow.DataType
- func (vr *DurationValueIterator) Next() bool
- func (vr *DurationValueIterator) Release()
- func (vr *DurationValueIterator) Retain()
- func (vr *DurationValueIterator) Value() (arrow.Duration, bool)
- func (vr *DurationValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *DurationValueIterator) ValueInterface() interface{}
- func (vr *DurationValueIterator) ValuePointer() *arrow.Duration
- type Float16ChunkIterator
- type Float16ValueIterator
- func (vr *Float16ValueIterator) DataType() arrow.DataType
- func (vr *Float16ValueIterator) Next() bool
- func (vr *Float16ValueIterator) Release()
- func (vr *Float16ValueIterator) Retain()
- func (vr *Float16ValueIterator) Value() (float16.Num, bool)
- func (vr *Float16ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Float16ValueIterator) ValueInterface() interface{}
- func (vr *Float16ValueIterator) ValuePointer() *float16.Num
- type Float32ChunkIterator
- type Float32ValueIterator
- func (vr *Float32ValueIterator) DataType() arrow.DataType
- func (vr *Float32ValueIterator) Next() bool
- func (vr *Float32ValueIterator) Release()
- func (vr *Float32ValueIterator) Retain()
- func (vr *Float32ValueIterator) Value() (float32, bool)
- func (vr *Float32ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Float32ValueIterator) ValueInterface() interface{}
- func (vr *Float32ValueIterator) ValuePointer() *float32
- type Float64ChunkIterator
- type Float64ValueIterator
- func (vr *Float64ValueIterator) DataType() arrow.DataType
- func (vr *Float64ValueIterator) Next() bool
- func (vr *Float64ValueIterator) Release()
- func (vr *Float64ValueIterator) Retain()
- func (vr *Float64ValueIterator) Value() (float64, bool)
- func (vr *Float64ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Float64ValueIterator) ValueInterface() interface{}
- func (vr *Float64ValueIterator) ValuePointer() *float64
- type Int16ChunkIterator
- type Int16ValueIterator
- func (vr *Int16ValueIterator) DataType() arrow.DataType
- func (vr *Int16ValueIterator) Next() bool
- func (vr *Int16ValueIterator) Release()
- func (vr *Int16ValueIterator) Retain()
- func (vr *Int16ValueIterator) Value() (int16, bool)
- func (vr *Int16ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Int16ValueIterator) ValueInterface() interface{}
- func (vr *Int16ValueIterator) ValuePointer() *int16
- type Int32ChunkIterator
- type Int32ValueIterator
- func (vr *Int32ValueIterator) DataType() arrow.DataType
- func (vr *Int32ValueIterator) Next() bool
- func (vr *Int32ValueIterator) Release()
- func (vr *Int32ValueIterator) Retain()
- func (vr *Int32ValueIterator) Value() (int32, bool)
- func (vr *Int32ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Int32ValueIterator) ValueInterface() interface{}
- func (vr *Int32ValueIterator) ValuePointer() *int32
- type Int64ChunkIterator
- type Int64ValueIterator
- func (vr *Int64ValueIterator) DataType() arrow.DataType
- func (vr *Int64ValueIterator) Next() bool
- func (vr *Int64ValueIterator) Release()
- func (vr *Int64ValueIterator) Retain()
- func (vr *Int64ValueIterator) Value() (int64, bool)
- func (vr *Int64ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Int64ValueIterator) ValueInterface() interface{}
- func (vr *Int64ValueIterator) ValuePointer() *int64
- type Int8ChunkIterator
- type Int8ValueIterator
- func (vr *Int8ValueIterator) DataType() arrow.DataType
- func (vr *Int8ValueIterator) Next() bool
- func (vr *Int8ValueIterator) Release()
- func (vr *Int8ValueIterator) Retain()
- func (vr *Int8ValueIterator) Value() (int8, bool)
- func (vr *Int8ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Int8ValueIterator) ValueInterface() interface{}
- func (vr *Int8ValueIterator) ValuePointer() *int8
- type ListValueIterator
- type MonthIntervalChunkIterator
- type MonthIntervalValueIterator
- func (vr *MonthIntervalValueIterator) DataType() arrow.DataType
- func (vr *MonthIntervalValueIterator) Next() bool
- func (vr *MonthIntervalValueIterator) Release()
- func (vr *MonthIntervalValueIterator) Retain()
- func (vr *MonthIntervalValueIterator) Value() (arrow.MonthInterval, bool)
- func (vr *MonthIntervalValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *MonthIntervalValueIterator) ValueInterface() interface{}
- func (vr *MonthIntervalValueIterator) ValuePointer() *arrow.MonthInterval
- type StepIterator
- type StepValue
- type StringValueIterator
- func (vr *StringValueIterator) DataType() arrow.DataType
- func (vr *StringValueIterator) Next() bool
- func (vr *StringValueIterator) Release()
- func (vr *StringValueIterator) Retain()
- func (vr *StringValueIterator) Value() (string, bool)
- func (vr *StringValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *StringValueIterator) ValueInterface() interface{}
- func (vr *StringValueIterator) ValuePointer() *string
- type StructValueIterator
- func (vr *StructValueIterator) DataType() arrow.DataType
- func (vr *StructValueIterator) Next() bool
- func (vr *StructValueIterator) Release()
- func (vr *StructValueIterator) Retain()
- func (vr *StructValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *StructValueIterator) ValueInterface() interface{}
- type Time32ChunkIterator
- type Time32ValueIterator
- func (vr *Time32ValueIterator) DataType() arrow.DataType
- func (vr *Time32ValueIterator) Next() bool
- func (vr *Time32ValueIterator) Release()
- func (vr *Time32ValueIterator) Retain()
- func (vr *Time32ValueIterator) Value() (arrow.Time32, bool)
- func (vr *Time32ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Time32ValueIterator) ValueInterface() interface{}
- func (vr *Time32ValueIterator) ValuePointer() *arrow.Time32
- type Time64ChunkIterator
- type Time64ValueIterator
- func (vr *Time64ValueIterator) DataType() arrow.DataType
- func (vr *Time64ValueIterator) Next() bool
- func (vr *Time64ValueIterator) Release()
- func (vr *Time64ValueIterator) Retain()
- func (vr *Time64ValueIterator) Value() (arrow.Time64, bool)
- func (vr *Time64ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Time64ValueIterator) ValueInterface() interface{}
- func (vr *Time64ValueIterator) ValuePointer() *arrow.Time64
- type TimestampChunkIterator
- type TimestampValueIterator
- func (vr *TimestampValueIterator) DataType() arrow.DataType
- func (vr *TimestampValueIterator) Next() bool
- func (vr *TimestampValueIterator) Release()
- func (vr *TimestampValueIterator) Retain()
- func (vr *TimestampValueIterator) Value() (arrow.Timestamp, bool)
- func (vr *TimestampValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *TimestampValueIterator) ValueInterface() interface{}
- func (vr *TimestampValueIterator) ValuePointer() *arrow.Timestamp
- type Uint16ChunkIterator
- type Uint16ValueIterator
- func (vr *Uint16ValueIterator) DataType() arrow.DataType
- func (vr *Uint16ValueIterator) Next() bool
- func (vr *Uint16ValueIterator) Release()
- func (vr *Uint16ValueIterator) Retain()
- func (vr *Uint16ValueIterator) Value() (uint16, bool)
- func (vr *Uint16ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Uint16ValueIterator) ValueInterface() interface{}
- func (vr *Uint16ValueIterator) ValuePointer() *uint16
- type Uint32ChunkIterator
- type Uint32ValueIterator
- func (vr *Uint32ValueIterator) DataType() arrow.DataType
- func (vr *Uint32ValueIterator) Next() bool
- func (vr *Uint32ValueIterator) Release()
- func (vr *Uint32ValueIterator) Retain()
- func (vr *Uint32ValueIterator) Value() (uint32, bool)
- func (vr *Uint32ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Uint32ValueIterator) ValueInterface() interface{}
- func (vr *Uint32ValueIterator) ValuePointer() *uint32
- type Uint64ChunkIterator
- type Uint64ValueIterator
- func (vr *Uint64ValueIterator) DataType() arrow.DataType
- func (vr *Uint64ValueIterator) Next() bool
- func (vr *Uint64ValueIterator) Release()
- func (vr *Uint64ValueIterator) Retain()
- func (vr *Uint64ValueIterator) Value() (uint64, bool)
- func (vr *Uint64ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Uint64ValueIterator) ValueInterface() interface{}
- func (vr *Uint64ValueIterator) ValuePointer() *uint64
- type Uint8ChunkIterator
- type Uint8ValueIterator
- func (vr *Uint8ValueIterator) DataType() arrow.DataType
- func (vr *Uint8ValueIterator) Next() bool
- func (vr *Uint8ValueIterator) Release()
- func (vr *Uint8ValueIterator) Retain()
- func (vr *Uint8ValueIterator) Value() (uint8, bool)
- func (vr *Uint8ValueIterator) ValueAsJSON() (interface{}, error)
- func (vr *Uint8ValueIterator) ValueInterface() interface{}
- func (vr *Uint8ValueIterator) ValuePointer() *uint8
- type ValueIterator
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) DataType ¶
func (vr *BooleanValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *BooleanValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *Date32ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Date32ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *Date64ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Date64ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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 DayTimeIntervalChunkIterator ¶
type DayTimeIntervalChunkIterator struct {
// contains filtered or unexported fields
}
DayTimeIntervalChunkIterator is an iterator for reading an Arrow Column value by value.
func NewDayTimeIntervalChunkIterator ¶
func NewDayTimeIntervalChunkIterator(col *array.Column) *DayTimeIntervalChunkIterator
NewDayTimeIntervalChunkIterator creates a new DayTimeIntervalChunkIterator for reading an Arrow Column.
func (*DayTimeIntervalChunkIterator) Chunk ¶
func (cr *DayTimeIntervalChunkIterator) Chunk() *array.DayTimeInterval
Chunk will return the current chunk that the iterator is on.
func (*DayTimeIntervalChunkIterator) ChunkValues ¶
func (cr *DayTimeIntervalChunkIterator) ChunkValues() []arrow.DayTimeInterval
ChunkValues returns the underlying []arrow.DayTimeInterval chunk values. Keep in mind the []arrow.DayTimeInterval type might not be able to account for nil values. You must check for those explicitly via the chunk.
func (*DayTimeIntervalChunkIterator) Next ¶
func (cr *DayTimeIntervalChunkIterator) Next() bool
Next moves the iterator to the next chunk. This will return false when there are no more chunks.
func (*DayTimeIntervalChunkIterator) Release ¶
func (cr *DayTimeIntervalChunkIterator) Release()
Release removes a reference to the DayTimeIntervalChunkIterator
func (*DayTimeIntervalChunkIterator) Retain ¶
func (cr *DayTimeIntervalChunkIterator) Retain()
Retain keeps a reference to the DayTimeIntervalChunkIterator
type DayTimeIntervalValueIterator ¶
type DayTimeIntervalValueIterator struct {
// contains filtered or unexported fields
}
DayTimeIntervalValueIterator is an iterator for reading an Arrow Column value by value.
func NewDayTimeIntervalValueIterator ¶
func NewDayTimeIntervalValueIterator(col *array.Column) *DayTimeIntervalValueIterator
NewDayTimeIntervalValueIterator creates a new DayTimeIntervalValueIterator for reading an Arrow Column.
func (*DayTimeIntervalValueIterator) DataType ¶
func (vr *DayTimeIntervalValueIterator) DataType() arrow.DataType
func (*DayTimeIntervalValueIterator) Next ¶
func (vr *DayTimeIntervalValueIterator) Next() bool
Next moves the iterator to the next value. This will return false when there are no more values.
func (*DayTimeIntervalValueIterator) Release ¶
func (vr *DayTimeIntervalValueIterator) Release()
Release removes a reference to the DayTimeIntervalValueIterator.
func (*DayTimeIntervalValueIterator) Retain ¶
func (vr *DayTimeIntervalValueIterator) Retain()
Retain keeps a reference to the DayTimeIntervalValueIterator.
func (*DayTimeIntervalValueIterator) Value ¶
func (vr *DayTimeIntervalValueIterator) Value() (arrow.DayTimeInterval, bool)
Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.
func (*DayTimeIntervalValueIterator) ValueAsJSON ¶
func (vr *DayTimeIntervalValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
func (*DayTimeIntervalValueIterator) ValueInterface ¶
func (vr *DayTimeIntervalValueIterator) ValueInterface() interface{}
ValueInterface returns the current value as an interface{}.
func (*DayTimeIntervalValueIterator) ValuePointer ¶
func (vr *DayTimeIntervalValueIterator) ValuePointer() *arrow.DayTimeInterval
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 Decimal128ChunkIterator ¶
type Decimal128ChunkIterator struct {
// contains filtered or unexported fields
}
Decimal128ChunkIterator is an iterator for reading an Arrow Column value by value.
func NewDecimal128ChunkIterator ¶
func NewDecimal128ChunkIterator(col *array.Column) *Decimal128ChunkIterator
NewDecimal128ChunkIterator creates a new Decimal128ChunkIterator for reading an Arrow Column.
func (*Decimal128ChunkIterator) Chunk ¶
func (cr *Decimal128ChunkIterator) Chunk() *array.Decimal128
Chunk will return the current chunk that the iterator is on.
func (*Decimal128ChunkIterator) ChunkValues ¶
func (cr *Decimal128ChunkIterator) ChunkValues() []decimal128.Num
ChunkValues returns the underlying []decimal128.Num chunk values. Keep in mind the []decimal128.Num type might not be able to account for nil values. You must check for those explicitly via the chunk.
func (*Decimal128ChunkIterator) Next ¶
func (cr *Decimal128ChunkIterator) Next() bool
Next moves the iterator to the next chunk. This will return false when there are no more chunks.
func (*Decimal128ChunkIterator) Release ¶
func (cr *Decimal128ChunkIterator) Release()
Release removes a reference to the Decimal128ChunkIterator
func (*Decimal128ChunkIterator) Retain ¶
func (cr *Decimal128ChunkIterator) Retain()
Retain keeps a reference to the Decimal128ChunkIterator
type Decimal128ValueIterator ¶
type Decimal128ValueIterator struct {
// contains filtered or unexported fields
}
Decimal128ValueIterator is an iterator for reading an Arrow Column value by value.
func NewDecimal128ValueIterator ¶
func NewDecimal128ValueIterator(col *array.Column) *Decimal128ValueIterator
NewDecimal128ValueIterator creates a new Decimal128ValueIterator for reading an Arrow Column.
func (*Decimal128ValueIterator) DataType ¶
func (vr *Decimal128ValueIterator) DataType() arrow.DataType
func (*Decimal128ValueIterator) Next ¶
func (vr *Decimal128ValueIterator) Next() bool
Next moves the iterator to the next value. This will return false when there are no more values.
func (*Decimal128ValueIterator) Release ¶
func (vr *Decimal128ValueIterator) Release()
Release removes a reference to the Decimal128ValueIterator.
func (*Decimal128ValueIterator) Retain ¶
func (vr *Decimal128ValueIterator) Retain()
Retain keeps a reference to the Decimal128ValueIterator.
func (*Decimal128ValueIterator) Value ¶
func (vr *Decimal128ValueIterator) Value() (decimal128.Num, bool)
Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.
func (*Decimal128ValueIterator) ValueAsJSON ¶
func (vr *Decimal128ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
func (*Decimal128ValueIterator) ValueInterface ¶
func (vr *Decimal128ValueIterator) ValueInterface() interface{}
ValueInterface returns the current value as an interface{}.
func (*Decimal128ValueIterator) ValuePointer ¶
func (vr *Decimal128ValueIterator) ValuePointer() *decimal128.Num
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 DurationChunkIterator ¶
type DurationChunkIterator struct {
// contains filtered or unexported fields
}
DurationChunkIterator is an iterator for reading an Arrow Column value by value.
func NewDurationChunkIterator ¶
func NewDurationChunkIterator(col *array.Column) *DurationChunkIterator
NewDurationChunkIterator creates a new DurationChunkIterator for reading an Arrow Column.
func (*DurationChunkIterator) Chunk ¶
func (cr *DurationChunkIterator) Chunk() *array.Duration
Chunk will return the current chunk that the iterator is on.
func (*DurationChunkIterator) ChunkValues ¶
func (cr *DurationChunkIterator) ChunkValues() []arrow.Duration
ChunkValues returns the underlying []arrow.Duration chunk values. Keep in mind the []arrow.Duration type might not be able to account for nil values. You must check for those explicitly via the chunk.
func (*DurationChunkIterator) Next ¶
func (cr *DurationChunkIterator) Next() bool
Next moves the iterator to the next chunk. This will return false when there are no more chunks.
func (*DurationChunkIterator) Release ¶
func (cr *DurationChunkIterator) Release()
Release removes a reference to the DurationChunkIterator
func (*DurationChunkIterator) Retain ¶
func (cr *DurationChunkIterator) Retain()
Retain keeps a reference to the DurationChunkIterator
type DurationValueIterator ¶
type DurationValueIterator struct {
// contains filtered or unexported fields
}
DurationValueIterator is an iterator for reading an Arrow Column value by value.
func NewDurationValueIterator ¶
func NewDurationValueIterator(col *array.Column) *DurationValueIterator
NewDurationValueIterator creates a new DurationValueIterator for reading an Arrow Column.
func (*DurationValueIterator) DataType ¶
func (vr *DurationValueIterator) DataType() arrow.DataType
func (*DurationValueIterator) Next ¶
func (vr *DurationValueIterator) Next() bool
Next moves the iterator to the next value. This will return false when there are no more values.
func (*DurationValueIterator) Release ¶
func (vr *DurationValueIterator) Release()
Release removes a reference to the DurationValueIterator.
func (*DurationValueIterator) Retain ¶
func (vr *DurationValueIterator) Retain()
Retain keeps a reference to the DurationValueIterator.
func (*DurationValueIterator) Value ¶
func (vr *DurationValueIterator) Value() (arrow.Duration, bool)
Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.
func (*DurationValueIterator) ValueAsJSON ¶
func (vr *DurationValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
func (*DurationValueIterator) ValueInterface ¶
func (vr *DurationValueIterator) ValueInterface() interface{}
ValueInterface returns the current value as an interface{}.
func (*DurationValueIterator) ValuePointer ¶
func (vr *DurationValueIterator) ValuePointer() *arrow.Duration
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 Float16ChunkIterator ¶
type Float16ChunkIterator struct {
// contains filtered or unexported fields
}
Float16ChunkIterator is an iterator for reading an Arrow Column value by value.
func NewFloat16ChunkIterator ¶
func NewFloat16ChunkIterator(col *array.Column) *Float16ChunkIterator
NewFloat16ChunkIterator creates a new Float16ChunkIterator for reading an Arrow Column.
func (*Float16ChunkIterator) Chunk ¶
func (cr *Float16ChunkIterator) Chunk() *array.Float16
Chunk will return the current chunk that the iterator is on.
func (*Float16ChunkIterator) ChunkValues ¶
func (cr *Float16ChunkIterator) ChunkValues() []float16.Num
ChunkValues returns the underlying []float16.Num chunk values. Keep in mind the []float16.Num type might not be able to account for nil values. You must check for those explicitly via the chunk.
func (*Float16ChunkIterator) Next ¶
func (cr *Float16ChunkIterator) Next() bool
Next moves the iterator to the next chunk. This will return false when there are no more chunks.
func (*Float16ChunkIterator) Release ¶
func (cr *Float16ChunkIterator) Release()
Release removes a reference to the Float16ChunkIterator
func (*Float16ChunkIterator) Retain ¶
func (cr *Float16ChunkIterator) Retain()
Retain keeps a reference to the Float16ChunkIterator
type Float16ValueIterator ¶
type Float16ValueIterator struct {
// contains filtered or unexported fields
}
Float16ValueIterator is an iterator for reading an Arrow Column value by value.
func NewFloat16ValueIterator ¶
func NewFloat16ValueIterator(col *array.Column) *Float16ValueIterator
NewFloat16ValueIterator creates a new Float16ValueIterator for reading an Arrow Column.
func (*Float16ValueIterator) DataType ¶
func (vr *Float16ValueIterator) DataType() arrow.DataType
func (*Float16ValueIterator) Next ¶
func (vr *Float16ValueIterator) Next() bool
Next moves the iterator to the next value. This will return false when there are no more values.
func (*Float16ValueIterator) Release ¶
func (vr *Float16ValueIterator) Release()
Release removes a reference to the Float16ValueIterator.
func (*Float16ValueIterator) Retain ¶
func (vr *Float16ValueIterator) Retain()
Retain keeps a reference to the Float16ValueIterator.
func (*Float16ValueIterator) Value ¶
func (vr *Float16ValueIterator) Value() (float16.Num, bool)
Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.
func (*Float16ValueIterator) ValueAsJSON ¶
func (vr *Float16ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
func (*Float16ValueIterator) ValueInterface ¶
func (vr *Float16ValueIterator) ValueInterface() interface{}
ValueInterface returns the current value as an interface{}.
func (*Float16ValueIterator) ValuePointer ¶
func (vr *Float16ValueIterator) ValuePointer() *float16.Num
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) DataType ¶
func (vr *Float32ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Float32ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *Float64ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Float64ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *Int16ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Int16ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *Int32ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Int32ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *Int64ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Int64ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *Int8ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Int8ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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 ListValueIterator ¶
type ListValueIterator struct {
// contains filtered or unexported fields
}
ListValueIterator iterates over the list elements. For example, in a list like: [[0 1 2] (null) [3 4 5] [6 7 8] (null)] First [0 1 2] would be returned, then (null), then [3 4 5], etc..
func NewListValueIterator ¶
func NewListValueIterator(col *array.Column) *ListValueIterator
func (*ListValueIterator) DataType ¶
func (vr *ListValueIterator) DataType() arrow.DataType
func (*ListValueIterator) Next ¶
func (vr *ListValueIterator) Next() bool
func (*ListValueIterator) Release ¶
func (vr *ListValueIterator) Release()
Release removes a reference to the ListValueIterator
func (*ListValueIterator) Retain ¶
func (vr *ListValueIterator) Retain()
Retain keeps a reference to the ListValueIterator
func (*ListValueIterator) ValueAsJSON ¶
func (vr *ListValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
func (*ListValueIterator) ValueInterface ¶
func (vr *ListValueIterator) ValueInterface() interface{}
type MonthIntervalChunkIterator ¶
type MonthIntervalChunkIterator struct {
// contains filtered or unexported fields
}
MonthIntervalChunkIterator is an iterator for reading an Arrow Column value by value.
func NewMonthIntervalChunkIterator ¶
func NewMonthIntervalChunkIterator(col *array.Column) *MonthIntervalChunkIterator
NewMonthIntervalChunkIterator creates a new MonthIntervalChunkIterator for reading an Arrow Column.
func (*MonthIntervalChunkIterator) Chunk ¶
func (cr *MonthIntervalChunkIterator) Chunk() *array.MonthInterval
Chunk will return the current chunk that the iterator is on.
func (*MonthIntervalChunkIterator) ChunkValues ¶
func (cr *MonthIntervalChunkIterator) ChunkValues() []arrow.MonthInterval
ChunkValues returns the underlying []arrow.MonthInterval chunk values. Keep in mind the []arrow.MonthInterval type might not be able to account for nil values. You must check for those explicitly via the chunk.
func (*MonthIntervalChunkIterator) Next ¶
func (cr *MonthIntervalChunkIterator) Next() bool
Next moves the iterator to the next chunk. This will return false when there are no more chunks.
func (*MonthIntervalChunkIterator) Release ¶
func (cr *MonthIntervalChunkIterator) Release()
Release removes a reference to the MonthIntervalChunkIterator
func (*MonthIntervalChunkIterator) Retain ¶
func (cr *MonthIntervalChunkIterator) Retain()
Retain keeps a reference to the MonthIntervalChunkIterator
type MonthIntervalValueIterator ¶
type MonthIntervalValueIterator struct {
// contains filtered or unexported fields
}
MonthIntervalValueIterator is an iterator for reading an Arrow Column value by value.
func NewMonthIntervalValueIterator ¶
func NewMonthIntervalValueIterator(col *array.Column) *MonthIntervalValueIterator
NewMonthIntervalValueIterator creates a new MonthIntervalValueIterator for reading an Arrow Column.
func (*MonthIntervalValueIterator) DataType ¶
func (vr *MonthIntervalValueIterator) DataType() arrow.DataType
func (*MonthIntervalValueIterator) Next ¶
func (vr *MonthIntervalValueIterator) Next() bool
Next moves the iterator to the next value. This will return false when there are no more values.
func (*MonthIntervalValueIterator) Release ¶
func (vr *MonthIntervalValueIterator) Release()
Release removes a reference to the MonthIntervalValueIterator.
func (*MonthIntervalValueIterator) Retain ¶
func (vr *MonthIntervalValueIterator) Retain()
Retain keeps a reference to the MonthIntervalValueIterator.
func (*MonthIntervalValueIterator) Value ¶
func (vr *MonthIntervalValueIterator) Value() (arrow.MonthInterval, bool)
Value will return the current value that the iterator is on and boolean value indicating if the value is actually null.
func (*MonthIntervalValueIterator) ValueAsJSON ¶
func (vr *MonthIntervalValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
func (*MonthIntervalValueIterator) ValueInterface ¶
func (vr *MonthIntervalValueIterator) ValueInterface() interface{}
ValueInterface returns the current value as an interface{}.
func (*MonthIntervalValueIterator) ValuePointer ¶
func (vr *MonthIntervalValueIterator) ValuePointer() *arrow.MonthInterval
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 ValuesJSON() (*StepValue, error) 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{} ValuesJSON []interface{} Exists []bool Dtypes []arrow.DataType }
StepValue holds the value for a given step.
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) DataType ¶
func (vr *StringValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *StringValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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 StructValueIterator ¶
type StructValueIterator struct {
// contains filtered or unexported fields
}
StructValueIterator iterates over the struct elements. {["f0:0" (null) "f0:9"] ["f1:0" (null) "f1:9"] [0 (null) 9]} It's a little different in that everything needs to be done from the field level.
func NewStructValueIterator ¶
func NewStructValueIterator(col *array.Column) *StructValueIterator
func (*StructValueIterator) DataType ¶
func (vr *StructValueIterator) DataType() arrow.DataType
func (*StructValueIterator) Next ¶
func (vr *StructValueIterator) Next() bool
func (*StructValueIterator) Release ¶
func (vr *StructValueIterator) Release()
Release removes a reference to the StructValueIterator
func (*StructValueIterator) Retain ¶
func (vr *StructValueIterator) Retain()
Retain keeps a reference to the StructValueIterator
func (*StructValueIterator) ValueAsJSON ¶
func (vr *StructValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
func (*StructValueIterator) ValueInterface ¶
func (vr *StructValueIterator) ValueInterface() interface{}
For this we return []ValueIterators so the user can do what they want with them.
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) DataType ¶
func (vr *Time32ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Time32ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *Time64ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Time64ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *TimestampValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *TimestampValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *Uint16ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Uint16ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *Uint32ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Uint32ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *Uint64ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Uint64ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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) DataType ¶
func (vr *Uint8ValueIterator) DataType() arrow.DataType
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) ValueAsJSON ¶
func (vr *Uint8ValueIterator) ValueAsJSON() (interface{}, error)
ValueAsJSON returns the current value as an interface{} in it's JSON representation.
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{} // ValueAsJSON returns the current value as an interface{} in it's JSON representation. ValueAsJSON() (interface{}, error) // DataType returns the DataType for the Column being iterated over. DataType() arrow.DataType // 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 NewInterfaceValueIterator ¶
func NewInterfaceValueIterator(field arrow.Field, iface array.Interface) ValueIterator
func NewValueIterator ¶
func NewValueIterator(column *array.Column) ValueIterator
NewValueIterator creates a new generic ValueIterator.