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 ¶
- type BooleanValueIterator
- type ChunkIterator
- type Date32ChunkIterator
- type Date32ValueIterator
- func (vr *Date32ValueIterator) Next() bool
- func (vr *Date32ValueIterator) Release()
- func (vr *Date32ValueIterator) Retain()
- func (vr *Date32ValueIterator) Value() (arrow.Date32, bool)
- func (vr *Date32ValueIterator) ValueInterface() interface{}
- func (vr *Date32ValueIterator) ValuePointer() *arrow.Date32
- type Date64ChunkIterator
- type Date64ValueIterator
- func (vr *Date64ValueIterator) Next() bool
- func (vr *Date64ValueIterator) Release()
- func (vr *Date64ValueIterator) Retain()
- func (vr *Date64ValueIterator) Value() (arrow.Date64, bool)
- func (vr *Date64ValueIterator) ValueInterface() interface{}
- func (vr *Date64ValueIterator) ValuePointer() *arrow.Date64
- type Float32ChunkIterator
- type Float32ValueIterator
- type Float64ChunkIterator
- type Float64ValueIterator
- type Int16ChunkIterator
- type Int16ValueIterator
- type Int32ChunkIterator
- type Int32ValueIterator
- type Int64ChunkIterator
- type Int64ValueIterator
- type Int8ChunkIterator
- type Int8ValueIterator
- type StepIterator
- type StepValue
- type StringValueIterator
- type Time32ChunkIterator
- type Time32ValueIterator
- func (vr *Time32ValueIterator) Next() bool
- func (vr *Time32ValueIterator) Release()
- func (vr *Time32ValueIterator) Retain()
- func (vr *Time32ValueIterator) Value() (arrow.Time32, bool)
- func (vr *Time32ValueIterator) ValueInterface() interface{}
- func (vr *Time32ValueIterator) ValuePointer() *arrow.Time32
- type Time64ChunkIterator
- type Time64ValueIterator
- func (vr *Time64ValueIterator) Next() bool
- func (vr *Time64ValueIterator) Release()
- func (vr *Time64ValueIterator) Retain()
- func (vr *Time64ValueIterator) Value() (arrow.Time64, bool)
- func (vr *Time64ValueIterator) ValueInterface() interface{}
- func (vr *Time64ValueIterator) ValuePointer() *arrow.Time64
- type TimestampChunkIterator
- type TimestampValueIterator
- func (vr *TimestampValueIterator) Next() bool
- func (vr *TimestampValueIterator) Release()
- func (vr *TimestampValueIterator) Retain()
- func (vr *TimestampValueIterator) Value() (arrow.Timestamp, bool)
- func (vr *TimestampValueIterator) ValueInterface() interface{}
- func (vr *TimestampValueIterator) ValuePointer() *arrow.Timestamp
- type Uint16ChunkIterator
- type Uint16ValueIterator
- type Uint32ChunkIterator
- type Uint32ValueIterator
- type Uint64ChunkIterator
- type Uint64ValueIterator
- type Uint8ChunkIterator
- type Uint8ValueIterator
- 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) 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 ¶
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 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.