array

package
v9.0.0 Latest Latest
Warning

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

 Go to latest Published: Jul 29, 2022 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 8 more Imports: 25 Imported by: 20

Documentation

Overview

Package array provides implementations of various Arrow array types.

Index

Constants

View Source 
const (
	// UnknownNullCount specifies the NullN should be calculated from the null bitmap buffer.
	UnknownNullCount = -1
)

Variables

This section is empty.

Functions

func ApproxEqual 

func ApproxEqual(left, right arrow.Array, opts ...EqualOption) bool

ApproxEqual reports whether the two provided arrays are approximately equal. For non-floating point arrays, it is equivalent to ArrayEqual.

func ArrayApproxEqual deprecated 

func ArrayApproxEqual(left, right arrow.Array, opts ...EqualOption) bool

ArrayApproxEqual reports whether the two provided arrays are approximately equal. For non-floating point arrays, it is equivalent to ArrayEqual.

Deprecated: renamed to just ApproxEqual, this alias will be removed in v9. Please update calling code to just call array.ApproxEqual

func ArrayEqual deprecated 

func ArrayEqual(left, right arrow.Array) bool

ArrayEqual reports whether the two provided arrays are equal.

Deprecated: This currently just delegates to calling Equal. This will be removed in v9 so please update any calling code to just call array.Equal directly instead.

func ArraySliceApproxEqual deprecated 

func ArraySliceApproxEqual(left arrow.Array, lbeg, lend int64, right arrow.Array, rbeg, rend int64, opts ...EqualOption) bool

ArraySliceApproxEqual reports whether slices left[lbeg:lend] and right[rbeg:rend] are approximately equal.

Deprecated: renamed to just SliceApproxEqual and will be removed in v9. Please update calling code to just call array.SliceApproxEqual.

func ArraySliceEqual deprecated 

func ArraySliceEqual(left arrow.Array, lbeg, lend int64, right arrow.Array, rbeg, rend int64) bool

ArraySliceEqual reports whether slices left[lbeg:lend] and right[rbeg:rend] are equal.

Deprecated: Renamed to just array.SliceEqual, this currently will just delegate to the renamed function and will be removed in v9. Please update any calling code.

func ChunkedApproxEqual 

func ChunkedApproxEqual(left, right *arrow.Chunked, opts ...EqualOption) bool

ChunkedApproxEqual reports whether two chunked arrays are approximately equal regardless of their chunkings for non-floating point arrays, this is equivalent to ChunkedEqual

func ChunkedEqual 

func ChunkedEqual(left, right *arrow.Chunked) bool

ChunkedEqual reports whether two chunked arrays are equal regardless of their chunkings

func Concatenate 

func Concatenate(arrs []arrow.Array, mem memory.Allocator) (result arrow.Array, err error)

Concatenate creates a new arrow.Array which is the concatenation of the passed in arrays. Returns nil if an error is encountered.

The passed in arrays still need to be released manually, and will not be released by this function.

func DictArrayFromJSON 

func DictArrayFromJSON(mem memory.Allocator, dt *arrow.DictionaryType, indicesJSON, dictJSON string) (arrow.Array, error)

func Equal 

func Equal(left, right arrow.Array) bool

Equal reports whether the two provided arrays are equal.

func FromJSON 

func FromJSON(mem memory.Allocator, dt arrow.DataType, r io.Reader, opts ...FromJSONOption) (arr arrow.Array, offset int64, err error)

FromJSON creates an arrow.Array from a corresponding JSON stream and defined data type. If the types in the json do not match the type provided, it will return errors. This is *not* the integration test format and should not be used as such. This intended to be used by consumers more similarly to the current exposing of the csv reader/writer. It also returns the input offset in the reader where it finished decoding since buffering by the decoder could leave the reader's cursor past where the parsing finished if attempting to parse multiple json arrays from one stream.

All the Array types implement json.Marshaller and thus can be written to json using the json.Marshal function

The JSON provided must be formatted in one of two ways: 

Default: the top level of the json must be a list which matches the type specified exactly
Example: `[1, 2, 3, 4, 5]` for any integer type or `[[...], null, [], .....]` for a List type
			Struct arrays are represented a list of objects: `[{"foo": 1, "bar": "moo"}, {"foo": 5, "bar": "baz"}]`

Using WithMultipleDocs:
	If the JSON provided is multiple newline separated json documents, then use this option
	and each json document will be treated as a single row of the array. This is most useful for record batches
	and interacting with other processes that use json. For example:
		`{"col1": 1, "col2": "row1", "col3": ...}\n{"col1": 2, "col2": "row2", "col3": ...}\n.....`

Duration values get formated upon marshalling as a string consisting of their numeric value followed by the unit suffix such as "10s" for a value of 10 and unit of Seconds. with "ms" for millisecond, "us" for microsecond, and "ns" for nanosecond as the suffixes. Unmarshalling duration values is more permissive since it first tries to use Go's time.ParseDuration function which means it allows values in the form 3h25m0.3s in addition to the same values which are output.

Interval types are marshalled / unmarshalled as follows: 

 MonthInterval is marshalled as an object with the format:
	 { "months": #}
 DayTimeInterval is marshalled using Go's regular marshalling of structs:
	 { "days": #, "milliseconds": # }
 MonthDayNanoInterval values are marshalled the same as DayTime using Go's struct marshalling:
  { "months": #, "days": #, "nanoseconds": # }

Times use a format of HH:MM or HH:MM:SS[.zzz] where the fractions of a second cannot exceed the precision allowed by the time unit, otherwise unmarshalling will error.

Dates use YYYY-MM-DD format

Timestamps use RFC3339Nano format except without a timezone, all of the following are valid: 

	YYYY-MM-DD
	YYYY-MM-DD[T]HH
	YYYY-MM-DD[T]HH:MM
 YYYY-MM-DD[T]HH:MM:SS[.zzzzzzzzzz]

The fractions of a second cannot exceed the precision allowed by the timeunit of the datatype.

When processing structs as objects order of keys does not matter, but keys cannot be repeated.

func Hash 

func Hash(h *maphash.Hash, data arrow.ArrayData)

func IsTrivialTransposition 

func IsTrivialTransposition(transposeMap []int32) bool

func MakeFromData 

func MakeFromData(data arrow.ArrayData) arrow.Array

MakeFromData constructs a strongly-typed array instance from generic Data.

func NewChunkedSlice 

func NewChunkedSlice(a *arrow.Chunked, i, j int64) *arrow.Chunked

NewChunkedSlice constructs a zero-copy slice of the chunked array with the indicated indices i and j, corresponding to array[i:j]. The returned chunked array must be Release()'d after use.

NewSlice panics if the slice is outside the valid range of the input array. NewSlice panics if j < i.

func NewColumnSlice 

func NewColumnSlice(col *arrow.Column, i, j int64) *arrow.Column

NewColumnSlice returns a new zero-copy slice of the column with the indicated indices i and j, corresponding to the column's array[i:j]. The returned column must be Release()'d after use.

NewColSlice panics if the slice is outside the valid range of the column's array. NewColSlice panics if j < i.

func NewExtensionArrayWithStorage 

func NewExtensionArrayWithStorage(dt arrow.ExtensionType, storage arrow.Array) arrow.Array

NewExtensionArrayWithStorage constructs a new ExtensionArray from the provided ExtensionType and uses the provided storage interface as the underlying storage. This will not release the storage array passed in so consumers should call Release on it manually while the new Extension array will share references to the underlying Data buffers.

func NewIntervalData 

func NewIntervalData(data arrow.ArrayData) arrow.Array

func NewRecord 

func NewRecord(schema *arrow.Schema, cols []arrow.Array, nrows int64) *simpleRecord

NewRecord returns a basic, non-lazy in-memory record batch.

NewRecord panics if the columns and schema are inconsistent. NewRecord panics if rows is larger than the height of the columns.

func NewRecordReader 

func NewRecordReader(schema *arrow.Schema, recs []arrow.Record) (*simpleRecords, error)

NewRecordReader returns a simple iterator over the given slice of records.

func NewSlice 

func NewSlice(arr arrow.Array, i, j int64) arrow.Array

NewSlice constructs a zero-copy slice of the array with the indicated indices i and j, corresponding to array[i:j]. The returned array must be Release()'d after use.

NewSlice panics if the slice is outside the valid range of the input array. NewSlice panics if j < i.

func NewSliceData 

func NewSliceData(data arrow.ArrayData, i, j int64) arrow.ArrayData

NewSliceData returns a new slice that shares backing data with the input. The returned Data slice starts at i and extends j-i elements, such as: 

slice := data[i:j]

The returned value must be Release'd after use.

NewSliceData panics if the slice is outside the valid range of the input Data. NewSliceData panics if j < i.

func NewTable 

func NewTable(schema *arrow.Schema, cols []arrow.Column, rows int64) *simpleTable

NewTable returns a new basic, non-lazy in-memory table. If rows is negative, the number of rows will be inferred from the height of the columns.

NewTable panics if the columns and schema are inconsistent. NewTable panics if rows is larger than the height of the columns.

func NewTableFromRecords 

func NewTableFromRecords(schema *arrow.Schema, recs []arrow.Record) *simpleTable

NewTableFromRecords returns a new basic, non-lazy in-memory table.

NewTableFromRecords panics if the records and schema are inconsistent.

func RecordApproxEqual 

func RecordApproxEqual(left, right arrow.Record, opts ...EqualOption) bool

RecordApproxEqual reports whether the two provided records are approximately equal. For non-floating point columns, it is equivalent to RecordEqual.

func RecordEqual 

func RecordEqual(left, right arrow.Record) bool

RecordEqual reports whether the two provided records are equal.

func RecordFromJSON 

func RecordFromJSON(mem memory.Allocator, schema *arrow.Schema, r io.Reader, opts ...FromJSONOption) (arrow.Record, int64, error)

RecordFromJSON creates a record batch from JSON data. See array.FromJSON for the details of formatting and logic.

A record batch from JSON is equivalent to reading a struct array in from json and then converting it to a record batch.

func RecordFromStructArray 

func RecordFromStructArray(in *Struct, schema *arrow.Schema) arrow.Record

RecordFromStructArray is a convenience function for converting a struct array into a record batch without copying the data. If the passed in schema is nil, the fields of the struct will be used to define the record batch. Otherwise the passed in schema will be used to create the record batch. If passed in, the schema must match the fields of the struct column.

func RecordToJSON 

func RecordToJSON(rec arrow.Record, w io.Writer) error

RecordToJSON writes out the given record following the format of each row is a single object on a single line of the output.

func SliceApproxEqual 

func SliceApproxEqual(left arrow.Array, lbeg, lend int64, right arrow.Array, rbeg, rend int64, opts ...EqualOption) bool

SliceApproxEqual reports whether slices left[lbeg:lend] and right[rbeg:rend] are approximately equal.

func SliceEqual 

func SliceEqual(left arrow.Array, lbeg, lend int64, right arrow.Array, rbeg, rend int64) bool

SliceEqual reports whether slices left[lbeg:lend] and right[rbeg:rend] are equal.

func TableApproxEqual 

func TableApproxEqual(left, right arrow.Table, opts ...EqualOption) bool

TableEqual returns if the two tables have the approximately equal data in the same schema

func TableEqual 

func TableEqual(left, right arrow.Table) bool

TableEqual returns if the two tables have the same data in the same schema

func TransposeDictIndices 

func TransposeDictIndices(mem memory.Allocator, data arrow.ArrayData, inType, outType arrow.DataType, dict arrow.ArrayData, transposeMap []int32) (arrow.ArrayData, error)

func UnifyChunkedDicts 

func UnifyChunkedDicts(alloc memory.Allocator, chnkd *arrow.Chunked) (*arrow.Chunked, error)

UnifyChunkedDicts takes a chunked array of dictionary type and will unify the dictionary across all of the chunks with the returned chunked array having all chunks share the same dictionary.

The return from this *must* have Release called on it unless an error is returned in which case the *arrow.Chunked will be nil.

If there is 1 or fewer chunks, then nothing is modified and this function will just call Retain on the passed in Chunked array (so Release can safely be called on it). The same is true if the type of the array is not a dictionary or if no changes are needed for all of the chunks to be using the same dictionary.

func UnifyTableDicts 

func UnifyTableDicts(alloc memory.Allocator, table arrow.Table) (arrow.Table, error)

UnifyTableDicts performs UnifyChunkedDicts on each column of the table so that any dictionary column will have the dictionaries of its chunks unified.

The returned Table should always be Release'd unless a non-nil error was returned, in which case the table returned will be nil.

Types

type Binary 

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

A type which represents an immutable sequence of variable-length binary strings.

func NewBinaryData 

func NewBinaryData(data arrow.ArrayData) *Binary

NewBinaryData constructs a new Binary array from data.

func (*Binary) Data 

func (a *Binary) Data() arrow.ArrayData

func (*Binary) DataType 

func (a *Binary) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Binary) IsNull 

func (a *Binary) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Binary) IsValid 

func (a *Binary) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Binary) Len 

func (a *Binary) Len() int

Len returns the number of elements in the array.

func (*Binary) MarshalJSON 

func (a *Binary) MarshalJSON() ([]byte, error)

func (*Binary) NullBitmapBytes 

func (a *Binary) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Binary) NullN 

func (a *Binary) NullN() int

NullN returns the number of null values in the array.

func (*Binary) Offset 

func (a *Binary) Offset() int

func (*Binary) Release 

func (a *Binary) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Binary) Retain 

func (a *Binary) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Binary) String 

func (a *Binary) String() string

func (*Binary) Value 

func (a *Binary) Value(i int) []byte

Value returns the slice at index i. This value should not be mutated.

func (*Binary) ValueBytes 

func (a *Binary) ValueBytes() []byte

func (*Binary) ValueLen 

func (a *Binary) ValueLen(i int) int

func (*Binary) ValueOffset 

func (a *Binary) ValueOffset(i int) int

func (*Binary) ValueOffsets 

func (a *Binary) ValueOffsets() []int32

func (*Binary) ValueString 

func (a *Binary) ValueString(i int) string

ValueString returns the string at index i without performing additional allocations. The string is only valid for the lifetime of the Binary array.

type BinaryBuilder 

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

A BinaryBuilder is used to build a Binary array using the Append methods.

func NewBinaryBuilder 

func NewBinaryBuilder(mem memory.Allocator, dtype arrow.BinaryDataType) *BinaryBuilder

func (*BinaryBuilder) Append 

func (b *BinaryBuilder) Append(v []byte)

func (*BinaryBuilder) AppendNull 

func (b *BinaryBuilder) AppendNull()

func (*BinaryBuilder) AppendString 

func (b *BinaryBuilder) AppendString(v string)

func (*BinaryBuilder) AppendStringValues 

func (b *BinaryBuilder) AppendStringValues(v []string, valid []bool)

AppendStringValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*BinaryBuilder) AppendValues 

func (b *BinaryBuilder) AppendValues(v [][]byte, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*BinaryBuilder) Cap 

func (b *BinaryBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*BinaryBuilder) DataCap 

func (b *BinaryBuilder) DataCap() int

DataCap returns the total number of bytes that can be stored without allocating additional memory.

func (*BinaryBuilder) DataLen 

func (b *BinaryBuilder) DataLen() int

DataLen returns the number of bytes in the data array.

func (*BinaryBuilder) Len 

func (b *BinaryBuilder) Len() int

Len returns the number of elements in the array builder.

func (*BinaryBuilder) NewArray 

func (b *BinaryBuilder) NewArray() arrow.Array

NewArray creates a Binary array from the memory buffers used by the builder and resets the BinaryBuilder so it can be used to build a new array.

func (*BinaryBuilder) NewBinaryArray 

func (b *BinaryBuilder) NewBinaryArray() (a *Binary)

NewBinaryArray creates a Binary array from the memory buffers used by the builder and resets the BinaryBuilder so it can be used to build a new array.

func (*BinaryBuilder) NullN 

func (b *BinaryBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*BinaryBuilder) Release 

func (b *BinaryBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed. Release may be called simultaneously from multiple goroutines.

func (*BinaryBuilder) Reserve 

func (b *BinaryBuilder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*BinaryBuilder) ReserveData 

func (b *BinaryBuilder) ReserveData(n int)

ReserveData ensures there is enough space for appending n bytes by checking the capacity and resizing the data buffer if necessary.

func (*BinaryBuilder) Resize 

func (b *BinaryBuilder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may be reduced.

func (*BinaryBuilder) ResizeData 

func (b *BinaryBuilder) ResizeData(n int)

func (*BinaryBuilder) Retain 

func (b *BinaryBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*BinaryBuilder) UnmarshalJSON 

func (b *BinaryBuilder) UnmarshalJSON(data []byte) error

func (*BinaryBuilder) UnsafeAppendBoolToBitmap 

func (b *BinaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)

func (*BinaryBuilder) Value 

func (b *BinaryBuilder) Value(i int) []byte

type BinaryDictionaryBuilder 

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

func (*BinaryDictionaryBuilder) Append 

func (b *BinaryDictionaryBuilder) Append(v []byte) error

func (*BinaryDictionaryBuilder) AppendArray 

func (b *BinaryDictionaryBuilder) AppendArray(arr arrow.Array) error

func (*BinaryDictionaryBuilder) AppendNull 

func (b *BinaryDictionaryBuilder) AppendNull()

func (*BinaryDictionaryBuilder) AppendString 

func (b *BinaryDictionaryBuilder) AppendString(v string) error

func (*BinaryDictionaryBuilder) Cap 

func (b *BinaryDictionaryBuilder) Cap() int

func (*BinaryDictionaryBuilder) InsertDictValues 

func (b *BinaryDictionaryBuilder) InsertDictValues(arr *Binary) (err error)

func (*BinaryDictionaryBuilder) InsertStringDictValues 

func (b *BinaryDictionaryBuilder) InsertStringDictValues(arr *String) (err error)

func (*BinaryDictionaryBuilder) NewArray 

func (b *BinaryDictionaryBuilder) NewArray() arrow.Array

func (*BinaryDictionaryBuilder) NewDelta 

func (b *BinaryDictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*BinaryDictionaryBuilder) NewDictionaryArray 

func (b *BinaryDictionaryBuilder) NewDictionaryArray() *Dictionary

func (*BinaryDictionaryBuilder) Release 

func (b *BinaryDictionaryBuilder) Release()

func (*BinaryDictionaryBuilder) Reserve 

func (b *BinaryDictionaryBuilder) Reserve(n int)

func (*BinaryDictionaryBuilder) ResetFull 

func (b *BinaryDictionaryBuilder) ResetFull()

func (*BinaryDictionaryBuilder) Resize 

func (b *BinaryDictionaryBuilder) Resize(n int)

func (*BinaryDictionaryBuilder) UnmarshalJSON 

func (b *BinaryDictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Boolean 

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

A type which represents an immutable sequence of boolean values.

func NewBoolean 

func NewBoolean(length int, data *memory.Buffer, nullBitmap *memory.Buffer, nulls int) *Boolean

NewBoolean creates a boolean array from the data memory.Buffer and contains length elements. The nullBitmap buffer can be nil of there are no null values. If nulls is not known, use UnknownNullCount to calculate the value of NullN at runtime from the nullBitmap buffer.

func NewBooleanData 

func NewBooleanData(data arrow.ArrayData) *Boolean

func (*Boolean) Data 

func (a *Boolean) Data() arrow.ArrayData

func (*Boolean) DataType 

func (a *Boolean) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Boolean) IsNull 

func (a *Boolean) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Boolean) IsValid 

func (a *Boolean) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Boolean) Len 

func (a *Boolean) Len() int

Len returns the number of elements in the array.

func (*Boolean) MarshalJSON 

func (a *Boolean) MarshalJSON() ([]byte, error)

func (*Boolean) NullBitmapBytes 

func (a *Boolean) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Boolean) NullN 

func (a *Boolean) NullN() int

NullN returns the number of null values in the array.

func (*Boolean) Offset 

func (a *Boolean) Offset() int

func (*Boolean) Release 

func (a *Boolean) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Boolean) Retain 

func (a *Boolean) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Boolean) String 

func (a *Boolean) String() string

func (*Boolean) Value 

func (a *Boolean) Value(i int) bool

type BooleanBuilder 

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

func NewBooleanBuilder 

func NewBooleanBuilder(mem memory.Allocator) *BooleanBuilder

func (*BooleanBuilder) Append 

func (b *BooleanBuilder) Append(v bool)

func (*BooleanBuilder) AppendByte 

func (b *BooleanBuilder) AppendByte(v byte)

func (*BooleanBuilder) AppendNull 

func (b *BooleanBuilder) AppendNull()

func (*BooleanBuilder) AppendValues 

func (b *BooleanBuilder) AppendValues(v []bool, valid []bool)

func (*BooleanBuilder) Cap 

func (b *BooleanBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*BooleanBuilder) Len 

func (b *BooleanBuilder) Len() int

Len returns the number of elements in the array builder.

func (*BooleanBuilder) NewArray 

func (b *BooleanBuilder) NewArray() arrow.Array

NewArray creates a Boolean array from the memory buffers used by the builder and resets the BooleanBuilder so it can be used to build a new array.

func (*BooleanBuilder) NewBooleanArray 

func (b *BooleanBuilder) NewBooleanArray() (a *Boolean)

NewBooleanArray creates a Boolean array from the memory buffers used by the builder and resets the BooleanBuilder so it can be used to build a new array.

func (*BooleanBuilder) NullN 

func (b *BooleanBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*BooleanBuilder) Release 

func (b *BooleanBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed. Release may be called simultaneously from multiple goroutines.

func (*BooleanBuilder) Reserve 

func (b *BooleanBuilder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*BooleanBuilder) Resize 

func (b *BooleanBuilder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*BooleanBuilder) Retain 

func (b *BooleanBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*BooleanBuilder) UnmarshalJSON 

func (b *BooleanBuilder) UnmarshalJSON(data []byte) error

func (*BooleanBuilder) UnsafeAppend 

func (b *BooleanBuilder) UnsafeAppend(v bool)

func (*BooleanBuilder) UnsafeAppendBoolToBitmap 

func (b *BooleanBuilder) UnsafeAppendBoolToBitmap(isValid bool)

type Builder 

type Builder interface {
	// you can unmarshal a json array to add the values to a builder
	json.Unmarshaler

	// Retain increases the reference count by 1.
	// Retain may be called simultaneously from multiple goroutines.
	Retain()

	// Release decreases the reference count by 1.
	Release()

	// Len returns the number of elements in the array builder.
	Len() int

	// Cap returns the total number of elements that can be stored
	// without allocating additional memory.
	Cap() int

	// NullN returns the number of null values in the array builder.
	NullN() int

	// AppendNull adds a new null value to the array being built.
	AppendNull()

	// Reserve ensures there is enough space for appending n elements
	// by checking the capacity and calling Resize if necessary.
	Reserve(n int)

	// Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(),
	// additional memory will be allocated. If n is smaller, the allocated memory may reduced.
	Resize(n int)

	// NewArray creates a new array from the memory buffers used
	// by the builder and resets the Builder so it can be used to build
	// a new array.
	NewArray() arrow.Array
	// contains filtered or unexported methods
}

Builder provides an interface to build arrow arrays.

func NewBuilder 

func NewBuilder(mem memory.Allocator, dtype arrow.DataType) Builder

type Data 

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

Data represents the memory and metadata of an Arrow array.

func NewData 

func NewData(dtype arrow.DataType, length int, buffers []*memory.Buffer, childData []arrow.ArrayData, nulls, offset int) *Data

NewData creates a new Data.

func NewDataWithDictionary 

func NewDataWithDictionary(dtype arrow.DataType, length int, buffers []*memory.Buffer, nulls, offset int, dict *Data) *Data

NewDataWithDictionary creates a new data object, but also sets the provided dictionary into the data if it's not nil

func (*Data) Buffers 

func (d *Data) Buffers() []*memory.Buffer

Buffers returns the buffers.

func (*Data) Children 

func (d *Data) Children() []arrow.ArrayData

func (*Data) DataType 

func (d *Data) DataType() arrow.DataType

DataType returns the DataType of the data.

func (*Data) Dictionary 

func (d *Data) Dictionary() arrow.ArrayData

Dictionary returns the ArrayData object for the dictionary member, or nil

func (*Data) Len 

func (d *Data) Len() int

Len returns the length.

func (*Data) NullN 

func (d *Data) NullN() int

NullN returns the number of nulls.

func (*Data) Offset 

func (d *Data) Offset() int

Offset returns the offset.

func (*Data) Release 

func (d *Data) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed. Release may be called simultaneously from multiple goroutines.

func (*Data) Reset 

func (d *Data) Reset(dtype arrow.DataType, length int, buffers []*memory.Buffer, childData []arrow.ArrayData, nulls, offset int)

Reset sets the Data for re-use.

func (*Data) Retain 

func (d *Data) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Data) SetDictionary 

func (d *Data) SetDictionary(dict arrow.ArrayData)

SetDictionary allows replacing the dictionary for this particular Data object

type Date32 

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

A type which represents an immutable sequence of arrow.Date32 values.

func NewDate32Data 

func NewDate32Data(data arrow.ArrayData) *Date32

NewDate32Data creates a new Date32.

func (*Date32) Data 

func (a *Date32) Data() arrow.ArrayData

func (*Date32) DataType 

func (a *Date32) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Date32) Date32Values 

func (a *Date32) Date32Values() []arrow.Date32

Values returns the values.

func (*Date32) IsNull 

func (a *Date32) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Date32) IsValid 

func (a *Date32) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Date32) Len 

func (a *Date32) Len() int

Len returns the number of elements in the array.

func (*Date32) MarshalJSON 

func (a *Date32) MarshalJSON() ([]byte, error)

func (*Date32) NullBitmapBytes 

func (a *Date32) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Date32) NullN 

func (a *Date32) NullN() int

NullN returns the number of null values in the array.

func (*Date32) Offset 

func (a *Date32) Offset() int

func (*Date32) Release 

func (a *Date32) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Date32) Reset 

func (a *Date32) Reset(data *Data)

Reset resets the array for re-use.

func (*Date32) Retain 

func (a *Date32) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Date32) String 

func (a *Date32) String() string

String returns a string representation of the array.

func (*Date32) Value 

func (a *Date32) Value(i int) arrow.Date32

Value returns the value at the specified index.

type Date32Builder 

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

func NewDate32Builder 

func NewDate32Builder(mem memory.Allocator) *Date32Builder

func (*Date32Builder) Append 

func (b *Date32Builder) Append(v arrow.Date32)

func (*Date32Builder) AppendNull 

func (b *Date32Builder) AppendNull()

func (*Date32Builder) AppendValues 

func (b *Date32Builder) AppendValues(v []arrow.Date32, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Date32Builder) Cap 

func (b *Date32Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Date32Builder) Len 

func (b *Date32Builder) Len() int

Len returns the number of elements in the array builder.

func (*Date32Builder) NewArray 

func (b *Date32Builder) NewArray() arrow.Array

NewArray creates a Date32 array from the memory buffers used by the builder and resets the Date32Builder so it can be used to build a new array.

func (*Date32Builder) NewDate32Array 

func (b *Date32Builder) NewDate32Array() (a *Date32)

NewDate32Array creates a Date32 array from the memory buffers used by the builder and resets the Date32Builder so it can be used to build a new array.

func (*Date32Builder) NullN 

func (b *Date32Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Date32Builder) Release 

func (b *Date32Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Date32Builder) Reserve 

func (b *Date32Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Date32Builder) Resize 

func (b *Date32Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Date32Builder) Retain 

func (b *Date32Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Date32Builder) UnmarshalJSON 

func (b *Date32Builder) UnmarshalJSON(data []byte) error

func (*Date32Builder) UnsafeAppend 

func (b *Date32Builder) UnsafeAppend(v arrow.Date32)

func (*Date32Builder) UnsafeAppendBoolToBitmap 

func (b *Date32Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Date32DictionaryBuilder 

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

func (*Date32DictionaryBuilder) Append 

func (b *Date32DictionaryBuilder) Append(v arrow.Date32) error

func (*Date32DictionaryBuilder) AppendArray 

func (b *Date32DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Date32DictionaryBuilder) AppendNull 

func (b *Date32DictionaryBuilder) AppendNull()

func (*Date32DictionaryBuilder) Cap 

func (b *Date32DictionaryBuilder) Cap() int

func (*Date32DictionaryBuilder) InsertDictValues 

func (b *Date32DictionaryBuilder) InsertDictValues(arr *Date32) (err error)

func (*Date32DictionaryBuilder) NewArray 

func (b *Date32DictionaryBuilder) NewArray() arrow.Array

func (*Date32DictionaryBuilder) NewDelta 

func (b *Date32DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Date32DictionaryBuilder) NewDictionaryArray 

func (b *Date32DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Date32DictionaryBuilder) Release 

func (b *Date32DictionaryBuilder) Release()

func (*Date32DictionaryBuilder) Reserve 

func (b *Date32DictionaryBuilder) Reserve(n int)

func (*Date32DictionaryBuilder) ResetFull 

func (b *Date32DictionaryBuilder) ResetFull()

func (*Date32DictionaryBuilder) Resize 

func (b *Date32DictionaryBuilder) Resize(n int)

func (*Date32DictionaryBuilder) UnmarshalJSON 

func (b *Date32DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Date64 

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

A type which represents an immutable sequence of arrow.Date64 values.

func NewDate64Data 

func NewDate64Data(data arrow.ArrayData) *Date64

NewDate64Data creates a new Date64.

func (*Date64) Data 

func (a *Date64) Data() arrow.ArrayData

func (*Date64) DataType 

func (a *Date64) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Date64) Date64Values 

func (a *Date64) Date64Values() []arrow.Date64

Values returns the values.

func (*Date64) IsNull 

func (a *Date64) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Date64) IsValid 

func (a *Date64) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Date64) Len 

func (a *Date64) Len() int

Len returns the number of elements in the array.

func (*Date64) MarshalJSON 

func (a *Date64) MarshalJSON() ([]byte, error)

func (*Date64) NullBitmapBytes 

func (a *Date64) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Date64) NullN 

func (a *Date64) NullN() int

NullN returns the number of null values in the array.

func (*Date64) Offset 

func (a *Date64) Offset() int

func (*Date64) Release 

func (a *Date64) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Date64) Reset 

func (a *Date64) Reset(data *Data)

Reset resets the array for re-use.

func (*Date64) Retain 

func (a *Date64) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Date64) String 

func (a *Date64) String() string

String returns a string representation of the array.

func (*Date64) Value 

func (a *Date64) Value(i int) arrow.Date64

Value returns the value at the specified index.

type Date64Builder 

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

func NewDate64Builder 

func NewDate64Builder(mem memory.Allocator) *Date64Builder

func (*Date64Builder) Append 

func (b *Date64Builder) Append(v arrow.Date64)

func (*Date64Builder) AppendNull 

func (b *Date64Builder) AppendNull()

func (*Date64Builder) AppendValues 

func (b *Date64Builder) AppendValues(v []arrow.Date64, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Date64Builder) Cap 

func (b *Date64Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Date64Builder) Len 

func (b *Date64Builder) Len() int

Len returns the number of elements in the array builder.

func (*Date64Builder) NewArray 

func (b *Date64Builder) NewArray() arrow.Array

NewArray creates a Date64 array from the memory buffers used by the builder and resets the Date64Builder so it can be used to build a new array.

func (*Date64Builder) NewDate64Array 

func (b *Date64Builder) NewDate64Array() (a *Date64)

NewDate64Array creates a Date64 array from the memory buffers used by the builder and resets the Date64Builder so it can be used to build a new array.

func (*Date64Builder) NullN 

func (b *Date64Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Date64Builder) Release 

func (b *Date64Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Date64Builder) Reserve 

func (b *Date64Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Date64Builder) Resize 

func (b *Date64Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Date64Builder) Retain 

func (b *Date64Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Date64Builder) UnmarshalJSON 

func (b *Date64Builder) UnmarshalJSON(data []byte) error

func (*Date64Builder) UnsafeAppend 

func (b *Date64Builder) UnsafeAppend(v arrow.Date64)

func (*Date64Builder) UnsafeAppendBoolToBitmap 

func (b *Date64Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Date64DictionaryBuilder 

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

func (*Date64DictionaryBuilder) Append 

func (b *Date64DictionaryBuilder) Append(v arrow.Date64) error

func (*Date64DictionaryBuilder) AppendArray 

func (b *Date64DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Date64DictionaryBuilder) AppendNull 

func (b *Date64DictionaryBuilder) AppendNull()

func (*Date64DictionaryBuilder) Cap 

func (b *Date64DictionaryBuilder) Cap() int

func (*Date64DictionaryBuilder) InsertDictValues 

func (b *Date64DictionaryBuilder) InsertDictValues(arr *Date64) (err error)

func (*Date64DictionaryBuilder) NewArray 

func (b *Date64DictionaryBuilder) NewArray() arrow.Array

func (*Date64DictionaryBuilder) NewDelta 

func (b *Date64DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Date64DictionaryBuilder) NewDictionaryArray 

func (b *Date64DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Date64DictionaryBuilder) Release 

func (b *Date64DictionaryBuilder) Release()

func (*Date64DictionaryBuilder) Reserve 

func (b *Date64DictionaryBuilder) Reserve(n int)

func (*Date64DictionaryBuilder) ResetFull 

func (b *Date64DictionaryBuilder) ResetFull()

func (*Date64DictionaryBuilder) Resize 

func (b *Date64DictionaryBuilder) Resize(n int)

func (*Date64DictionaryBuilder) UnmarshalJSON 

func (b *Date64DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type DayTimeDictionaryBuilder 

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

func (*DayTimeDictionaryBuilder) Append 

func (b *DayTimeDictionaryBuilder) Append(v arrow.DayTimeInterval) error

func (*DayTimeDictionaryBuilder) AppendArray 

func (b *DayTimeDictionaryBuilder) AppendArray(arr arrow.Array) error

func (*DayTimeDictionaryBuilder) AppendNull 

func (b *DayTimeDictionaryBuilder) AppendNull()

func (*DayTimeDictionaryBuilder) Cap 

func (b *DayTimeDictionaryBuilder) Cap() int

func (*DayTimeDictionaryBuilder) InsertDictValues 

func (b *DayTimeDictionaryBuilder) InsertDictValues(arr *DayTimeInterval) (err error)

func (*DayTimeDictionaryBuilder) NewArray 

func (b *DayTimeDictionaryBuilder) NewArray() arrow.Array

func (*DayTimeDictionaryBuilder) NewDelta 

func (b *DayTimeDictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*DayTimeDictionaryBuilder) NewDictionaryArray 

func (b *DayTimeDictionaryBuilder) NewDictionaryArray() *Dictionary

func (*DayTimeDictionaryBuilder) Release 

func (b *DayTimeDictionaryBuilder) Release()

func (*DayTimeDictionaryBuilder) Reserve 

func (b *DayTimeDictionaryBuilder) Reserve(n int)

func (*DayTimeDictionaryBuilder) ResetFull 

func (b *DayTimeDictionaryBuilder) ResetFull()

func (*DayTimeDictionaryBuilder) Resize 

func (b *DayTimeDictionaryBuilder) Resize(n int)

func (*DayTimeDictionaryBuilder) UnmarshalJSON 

func (b *DayTimeDictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type DayTimeInterval 

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

A type which represents an immutable sequence of arrow.DayTimeInterval values.

func NewDayTimeIntervalData 

func NewDayTimeIntervalData(data arrow.ArrayData) *DayTimeInterval

func (*DayTimeInterval) Data 

func (a *DayTimeInterval) Data() arrow.ArrayData

func (*DayTimeInterval) DataType 

func (a *DayTimeInterval) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*DayTimeInterval) DayTimeIntervalValues 

func (a *DayTimeInterval) DayTimeIntervalValues() []arrow.DayTimeInterval

func (*DayTimeInterval) IsNull 

func (a *DayTimeInterval) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*DayTimeInterval) IsValid 

func (a *DayTimeInterval) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*DayTimeInterval) Len 

func (a *DayTimeInterval) Len() int

Len returns the number of elements in the array.

func (*DayTimeInterval) MarshalJSON 

func (a *DayTimeInterval) MarshalJSON() ([]byte, error)

MarshalJSON will marshal this array to JSON as an array of objects, consisting of the form {"days": #, "milliseconds": #} for each element.

func (*DayTimeInterval) NullBitmapBytes 

func (a *DayTimeInterval) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*DayTimeInterval) NullN 

func (a *DayTimeInterval) NullN() int

NullN returns the number of null values in the array.

func (*DayTimeInterval) Offset 

func (a *DayTimeInterval) Offset() int

func (*DayTimeInterval) Release 

func (a *DayTimeInterval) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*DayTimeInterval) Retain 

func (a *DayTimeInterval) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*DayTimeInterval) String 

func (a *DayTimeInterval) String() string

func (*DayTimeInterval) Value 

func (a *DayTimeInterval) Value(i int) arrow.DayTimeInterval

type DayTimeIntervalBuilder 

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

func NewDayTimeIntervalBuilder 

func NewDayTimeIntervalBuilder(mem memory.Allocator) *DayTimeIntervalBuilder

func (*DayTimeIntervalBuilder) Append 

func (b *DayTimeIntervalBuilder) Append(v arrow.DayTimeInterval)

func (*DayTimeIntervalBuilder) AppendNull 

func (b *DayTimeIntervalBuilder) AppendNull()

func (*DayTimeIntervalBuilder) AppendValues 

func (b *DayTimeIntervalBuilder) AppendValues(v []arrow.DayTimeInterval, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*DayTimeIntervalBuilder) Cap 

func (b *DayTimeIntervalBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*DayTimeIntervalBuilder) Len 

func (b *DayTimeIntervalBuilder) Len() int

Len returns the number of elements in the array builder.

func (*DayTimeIntervalBuilder) NewArray 

func (b *DayTimeIntervalBuilder) NewArray() arrow.Array

NewArray creates a DayTimeInterval array from the memory buffers used by the builder and resets the DayTimeIntervalBuilder so it can be used to build a new array.

func (*DayTimeIntervalBuilder) NewDayTimeIntervalArray 

func (b *DayTimeIntervalBuilder) NewDayTimeIntervalArray() (a *DayTimeInterval)

NewDayTimeIntervalArray creates a DayTimeInterval array from the memory buffers used by the builder and resets the DayTimeIntervalBuilder so it can be used to build a new array.

func (*DayTimeIntervalBuilder) NullN 

func (b *DayTimeIntervalBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*DayTimeIntervalBuilder) Release 

func (b *DayTimeIntervalBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*DayTimeIntervalBuilder) Reserve 

func (b *DayTimeIntervalBuilder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*DayTimeIntervalBuilder) Resize 

func (b *DayTimeIntervalBuilder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*DayTimeIntervalBuilder) Retain 

func (b *DayTimeIntervalBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*DayTimeIntervalBuilder) UnmarshalJSON 

func (b *DayTimeIntervalBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON will add the values unmarshalled from an array to the builder, with the values expected to be objects of the form {"days": #, "milliseconds": #}

func (*DayTimeIntervalBuilder) UnsafeAppend 

func (b *DayTimeIntervalBuilder) UnsafeAppend(v arrow.DayTimeInterval)

func (*DayTimeIntervalBuilder) UnsafeAppendBoolToBitmap 

func (b *DayTimeIntervalBuilder) UnsafeAppendBoolToBitmap(isValid bool)

type Decimal128 

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

A type which represents an immutable sequence of 128-bit decimal values.

func NewDecimal128Data 

func NewDecimal128Data(data arrow.ArrayData) *Decimal128

func (*Decimal128) Data 

func (a *Decimal128) Data() arrow.ArrayData

func (*Decimal128) DataType 

func (a *Decimal128) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Decimal128) IsNull 

func (a *Decimal128) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Decimal128) IsValid 

func (a *Decimal128) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Decimal128) Len 

func (a *Decimal128) Len() int

Len returns the number of elements in the array.

func (*Decimal128) MarshalJSON 

func (a *Decimal128) MarshalJSON() ([]byte, error)

func (*Decimal128) NullBitmapBytes 

func (a *Decimal128) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Decimal128) NullN 

func (a *Decimal128) NullN() int

NullN returns the number of null values in the array.

func (*Decimal128) Offset 

func (a *Decimal128) Offset() int

func (*Decimal128) Release 

func (a *Decimal128) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Decimal128) Retain 

func (a *Decimal128) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Decimal128) String 

func (a *Decimal128) String() string

func (*Decimal128) Value 

func (a *Decimal128) Value(i int) decimal128.Num

func (*Decimal128) Values 

func (a *Decimal128) Values() []decimal128.Num

type Decimal128Builder 

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

func NewDecimal128Builder 

func NewDecimal128Builder(mem memory.Allocator, dtype *arrow.Decimal128Type) *Decimal128Builder

func (*Decimal128Builder) Append 

func (b *Decimal128Builder) Append(v decimal128.Num)

func (*Decimal128Builder) AppendNull 

func (b *Decimal128Builder) AppendNull()

func (*Decimal128Builder) AppendValues 

func (b *Decimal128Builder) AppendValues(v []decimal128.Num, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Decimal128Builder) Cap 

func (b *Decimal128Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Decimal128Builder) Len 

func (b *Decimal128Builder) Len() int

Len returns the number of elements in the array builder.

func (*Decimal128Builder) NewArray 

func (b *Decimal128Builder) NewArray() arrow.Array

NewArray creates a Decimal128 array from the memory buffers used by the builder and resets the Decimal128Builder so it can be used to build a new array.

func (*Decimal128Builder) NewDecimal128Array 

func (b *Decimal128Builder) NewDecimal128Array() (a *Decimal128)

NewDecimal128Array creates a Decimal128 array from the memory buffers used by the builder and resets the Decimal128Builder so it can be used to build a new array.

func (*Decimal128Builder) NullN 

func (b *Decimal128Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Decimal128Builder) Release 

func (b *Decimal128Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Decimal128Builder) Reserve 

func (b *Decimal128Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Decimal128Builder) Resize 

func (b *Decimal128Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Decimal128Builder) Retain 

func (b *Decimal128Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Decimal128Builder) UnmarshalJSON 

func (b *Decimal128Builder) UnmarshalJSON(data []byte) error

UnmarshalJSON will add the unmarshalled values to this builder.

If the values are strings, they will get parsed with big.ParseFloat using a rounding mode of big.ToNearestAway currently.

func (*Decimal128Builder) UnsafeAppend 

func (b *Decimal128Builder) UnsafeAppend(v decimal128.Num)

func (*Decimal128Builder) UnsafeAppendBoolToBitmap 

func (b *Decimal128Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Decimal128DictionaryBuilder 

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

func (*Decimal128DictionaryBuilder) Append 

func (b *Decimal128DictionaryBuilder) Append(v decimal128.Num) error

func (*Decimal128DictionaryBuilder) AppendArray 

func (b *Decimal128DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Decimal128DictionaryBuilder) AppendNull 

func (b *Decimal128DictionaryBuilder) AppendNull()

func (*Decimal128DictionaryBuilder) Cap 

func (b *Decimal128DictionaryBuilder) Cap() int

func (*Decimal128DictionaryBuilder) InsertDictValues 

func (b *Decimal128DictionaryBuilder) InsertDictValues(arr *Decimal128) (err error)

func (*Decimal128DictionaryBuilder) NewArray 

func (b *Decimal128DictionaryBuilder) NewArray() arrow.Array

func (*Decimal128DictionaryBuilder) NewDelta 

func (b *Decimal128DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Decimal128DictionaryBuilder) NewDictionaryArray 

func (b *Decimal128DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Decimal128DictionaryBuilder) Release 

func (b *Decimal128DictionaryBuilder) Release()

func (*Decimal128DictionaryBuilder) Reserve 

func (b *Decimal128DictionaryBuilder) Reserve(n int)

func (*Decimal128DictionaryBuilder) ResetFull 

func (b *Decimal128DictionaryBuilder) ResetFull()

func (*Decimal128DictionaryBuilder) Resize 

func (b *Decimal128DictionaryBuilder) Resize(n int)

func (*Decimal128DictionaryBuilder) UnmarshalJSON 

func (b *Decimal128DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Dictionary 

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

Dictionary represents the type for dictionary-encoded data with a data dependent dictionary.

A dictionary array contains an array of non-negative integers (the "dictionary" indices") along with a data type containing a "dictionary" corresponding to the distinct values represented in the data.

For example, the array: 

["foo", "bar", "foo", "bar", "foo", "bar"]

with dictionary ["bar", "foo"], would have the representation of: 

indices: [1, 0, 1, 0, 1, 0]
dictionary: ["bar", "foo"]

The indices in principle may be any integer type.

func NewDictionaryArray 

func NewDictionaryArray(typ arrow.DataType, indices, dict arrow.Array) *Dictionary

NewDictionaryArray constructs a dictionary array with the provided indices and dictionary using the given type.

func NewDictionaryData 

func NewDictionaryData(data arrow.ArrayData) *Dictionary

NewDictionaryData creates a strongly typed Dictionary array from an ArrayData object with a datatype of arrow.Dictionary and a dictionary

func NewValidatedDictionaryArray 

func NewValidatedDictionaryArray(typ *arrow.DictionaryType, indices, dict arrow.Array) (*Dictionary, error)

NewValidatedDictionaryArray constructs a dictionary array from the provided indices and dictionary arrays, while also performing validation checks to ensure correctness such as bounds checking at are usually skipped for performance.

func (*Dictionary) CanCompareIndices 

func (d *Dictionary) CanCompareIndices(other *Dictionary) bool

CanCompareIndices returns true if the dictionary arrays can be compared without having to unify the dictionaries themselves first. This means that the index types are equal too.

func (*Dictionary) Data 

func (a *Dictionary) Data() arrow.ArrayData

func (*Dictionary) DataType 

func (a *Dictionary) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Dictionary) Dictionary 

func (d *Dictionary) Dictionary() arrow.Array

Dictionary returns the values array that makes up the dictionary for this array.

func (*Dictionary) GetValueIndex 

func (d *Dictionary) GetValueIndex(i int) int

GetValueIndex returns the dictionary index for the value at index i of the array. The actual value can be retrieved by using d.Dictionary().(valuetype).Value(d.GetValueIndex(i))

func (*Dictionary) Indices 

func (d *Dictionary) Indices() arrow.Array

Indices returns the underlying array of indices as it's own array

func (*Dictionary) IsNull 

func (a *Dictionary) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Dictionary) IsValid 

func (a *Dictionary) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Dictionary) Len 

func (a *Dictionary) Len() int

Len returns the number of elements in the array.

func (*Dictionary) MarshalJSON 

func (d *Dictionary) MarshalJSON() ([]byte, error)

func (*Dictionary) NullBitmapBytes 

func (a *Dictionary) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Dictionary) NullN 

func (a *Dictionary) NullN() int

NullN returns the number of null values in the array.

func (*Dictionary) Offset 

func (a *Dictionary) Offset() int

func (*Dictionary) Release 

func (d *Dictionary) Release()

func (*Dictionary) Retain 

func (d *Dictionary) Retain()

func (*Dictionary) String 

func (d *Dictionary) String() string

type DictionaryBuilder 

type DictionaryBuilder interface {
	Builder

	NewDictionaryArray() *Dictionary
	NewDelta() (indices, delta arrow.Array, err error)
	AppendArray(arrow.Array) error
	ResetFull()
}

func NewDictionaryBuilder 

func NewDictionaryBuilder(mem memory.Allocator, dt *arrow.DictionaryType) DictionaryBuilder

func NewDictionaryBuilderWithDict 

func NewDictionaryBuilderWithDict(mem memory.Allocator, dt *arrow.DictionaryType, init arrow.Array) DictionaryBuilder

NewDictionaryBuilderWithDict initializes a dictionary builder and inserts the values from `init` as the first values in the dictionary, but does not insert them as values into the array.

type DictionaryUnifier 

type DictionaryUnifier interface {
	// Unify adds the provided array of dictionary values to be unified.
	Unify(arrow.Array) error
	// UnifyAndTranspose adds the provided array of dictionary values,
	// just like Unify but returns an allocated buffer containing a mapping
	// to transpose dictionary indices.
	UnifyAndTranspose(dict arrow.Array) (transposed *memory.Buffer, err error)
	// GetResult returns the dictionary type (choosing the smallest index type
	// that can represent all the values) and the new unified dictionary.
	//
	// Calling GetResult clears the existing dictionary from the unifier so it
	// can be reused by calling Unify/UnifyAndTranspose again with new arrays.
	GetResult() (outType arrow.DataType, outDict arrow.Array, err error)
	// GetResultWithIndexType is like GetResult, but allows specifying the type
	// of the dictionary indexes rather than letting the unifier pick. If the
	// passed in index type isn't large enough to represent all of the dictionary
	// values, an error will be returned instead. The new unified dictionary
	// is returned.
	GetResultWithIndexType(indexType arrow.DataType) (arrow.Array, error)
	// Release should be called to clean up any allocated scrach memo-table used
	// for building the unified dictionary.
	Release()
}

DictionaryUnifier defines the interface used for unifying, and optionally producing transposition maps for, multiple dictionary arrays incrementally.

func NewDictionaryUnifier 

func NewDictionaryUnifier(alloc memory.Allocator, valueType arrow.DataType) (DictionaryUnifier, error)

NewDictionaryUnifier constructs and returns a new dictionary unifier for dictionaries of valueType, using the provided allocator for allocating the unified dictionary and the memotable used for building it.

This will only work for non-nested types currently. a nested valueType or dictionary type will result in an error.

type Duration 

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

A type which represents an immutable sequence of arrow.Duration values.

func NewDurationData 

func NewDurationData(data arrow.ArrayData) *Duration

NewDurationData creates a new Duration.

func (*Duration) Data 

func (a *Duration) Data() arrow.ArrayData

func (*Duration) DataType 

func (a *Duration) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Duration) DurationValues 

func (a *Duration) DurationValues() []arrow.Duration

Values returns the values.

func (*Duration) IsNull 

func (a *Duration) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Duration) IsValid 

func (a *Duration) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Duration) Len 

func (a *Duration) Len() int

Len returns the number of elements in the array.

func (*Duration) MarshalJSON 

func (a *Duration) MarshalJSON() ([]byte, error)

func (*Duration) NullBitmapBytes 

func (a *Duration) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Duration) NullN 

func (a *Duration) NullN() int

NullN returns the number of null values in the array.

func (*Duration) Offset 

func (a *Duration) Offset() int

func (*Duration) Release 

func (a *Duration) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Duration) Reset 

func (a *Duration) Reset(data *Data)

Reset resets the array for re-use.

func (*Duration) Retain 

func (a *Duration) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Duration) String 

func (a *Duration) String() string

String returns a string representation of the array.

func (*Duration) Value 

func (a *Duration) Value(i int) arrow.Duration

Value returns the value at the specified index.

type DurationBuilder 

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

func NewDurationBuilder 

func NewDurationBuilder(mem memory.Allocator, dtype *arrow.DurationType) *DurationBuilder

func (*DurationBuilder) Append 

func (b *DurationBuilder) Append(v arrow.Duration)

func (*DurationBuilder) AppendNull 

func (b *DurationBuilder) AppendNull()

func (*DurationBuilder) AppendValues 

func (b *DurationBuilder) AppendValues(v []arrow.Duration, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*DurationBuilder) Cap 

func (b *DurationBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*DurationBuilder) Len 

func (b *DurationBuilder) Len() int

Len returns the number of elements in the array builder.

func (*DurationBuilder) NewArray 

func (b *DurationBuilder) NewArray() arrow.Array

NewArray creates a Duration array from the memory buffers used by the builder and resets the DurationBuilder so it can be used to build a new array.

func (*DurationBuilder) NewDurationArray 

func (b *DurationBuilder) NewDurationArray() (a *Duration)

NewDurationArray creates a Duration array from the memory buffers used by the builder and resets the DurationBuilder so it can be used to build a new array.

func (*DurationBuilder) NullN 

func (b *DurationBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*DurationBuilder) Release 

func (b *DurationBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*DurationBuilder) Reserve 

func (b *DurationBuilder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*DurationBuilder) Resize 

func (b *DurationBuilder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*DurationBuilder) Retain 

func (b *DurationBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*DurationBuilder) UnmarshalJSON 

func (b *DurationBuilder) UnmarshalJSON(data []byte) error

func (*DurationBuilder) UnsafeAppend 

func (b *DurationBuilder) UnsafeAppend(v arrow.Duration)

func (*DurationBuilder) UnsafeAppendBoolToBitmap 

func (b *DurationBuilder) UnsafeAppendBoolToBitmap(isValid bool)

type DurationDictionaryBuilder 

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

func (*DurationDictionaryBuilder) Append 

func (b *DurationDictionaryBuilder) Append(v arrow.Duration) error

func (*DurationDictionaryBuilder) AppendArray 

func (b *DurationDictionaryBuilder) AppendArray(arr arrow.Array) error

func (*DurationDictionaryBuilder) AppendNull 

func (b *DurationDictionaryBuilder) AppendNull()

func (*DurationDictionaryBuilder) Cap 

func (b *DurationDictionaryBuilder) Cap() int

func (*DurationDictionaryBuilder) InsertDictValues 

func (b *DurationDictionaryBuilder) InsertDictValues(arr *Duration) (err error)

func (*DurationDictionaryBuilder) NewArray 

func (b *DurationDictionaryBuilder) NewArray() arrow.Array

func (*DurationDictionaryBuilder) NewDelta 

func (b *DurationDictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*DurationDictionaryBuilder) NewDictionaryArray 

func (b *DurationDictionaryBuilder) NewDictionaryArray() *Dictionary

func (*DurationDictionaryBuilder) Release 

func (b *DurationDictionaryBuilder) Release()

func (*DurationDictionaryBuilder) Reserve 

func (b *DurationDictionaryBuilder) Reserve(n int)

func (*DurationDictionaryBuilder) ResetFull 

func (b *DurationDictionaryBuilder) ResetFull()

func (*DurationDictionaryBuilder) Resize 

func (b *DurationDictionaryBuilder) Resize(n int)

func (*DurationDictionaryBuilder) UnmarshalJSON 

func (b *DurationDictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type EqualOption 

type EqualOption func(*equalOption)

EqualOption is a functional option type used to configure how Records and Arrays are compared.

func WithAbsTolerance 

func WithAbsTolerance(atol float64) EqualOption

WithAbsTolerance configures the comparison functions so that 2 floating point values v1 and v2 are considered equal if |v1-v2| <= atol.

func WithNaNsEqual 

func WithNaNsEqual(v bool) EqualOption

WithNaNsEqual configures the comparison functions so that NaNs are considered equal.

type ExtensionArray 

type ExtensionArray interface {
	arrow.Array
	// ExtensionType returns the datatype as per calling DataType(), but
	// already cast to ExtensionType
	ExtensionType() arrow.ExtensionType
	// Storage returns the underlying storage array for this array.
	Storage() arrow.Array
	// contains filtered or unexported methods
}

ExtensionArray is the interface that needs to be implemented to handle user-defined extension type arrays. In order to ensure consistency and proper behavior, all ExtensionArray types must embed ExtensionArrayBase in order to meet the interface which provides the default implementation and handling for the array while allowing custom behavior to be built on top of it.

func NewExtensionData 

func NewExtensionData(data arrow.ArrayData) ExtensionArray

NewExtensionData expects a data with a datatype of arrow.ExtensionType and underlying data built for the storage array.

type ExtensionArrayBase 

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

ExtensionArrayBase is the base struct for user-defined Extension Array types and must be embedded in any user-defined extension arrays like so: 

type UserDefinedArray struct {
    array.ExtensionArrayBase
}

func (*ExtensionArrayBase) Data 

func (a *ExtensionArrayBase) Data() arrow.ArrayData

func (*ExtensionArrayBase) DataType 

func (a *ExtensionArrayBase) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*ExtensionArrayBase) ExtensionType 

func (e *ExtensionArrayBase) ExtensionType() arrow.ExtensionType

ExtensionType returns the same thing as DataType, just already casted to an ExtensionType interface for convenience.

func (*ExtensionArrayBase) IsNull 

func (a *ExtensionArrayBase) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*ExtensionArrayBase) IsValid 

func (a *ExtensionArrayBase) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*ExtensionArrayBase) Len 

func (a *ExtensionArrayBase) Len() int

Len returns the number of elements in the array.

func (*ExtensionArrayBase) MarshalJSON 

func (e *ExtensionArrayBase) MarshalJSON() ([]byte, error)

func (*ExtensionArrayBase) NullBitmapBytes 

func (a *ExtensionArrayBase) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*ExtensionArrayBase) NullN 

func (a *ExtensionArrayBase) NullN() int

NullN returns the number of null values in the array.

func (*ExtensionArrayBase) Offset 

func (a *ExtensionArrayBase) Offset() int

func (*ExtensionArrayBase) Release 

func (e *ExtensionArrayBase) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*ExtensionArrayBase) Retain 

func (e *ExtensionArrayBase) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*ExtensionArrayBase) Storage 

func (e *ExtensionArrayBase) Storage() arrow.Array

Storage returns the underlying storage array

func (*ExtensionArrayBase) String 

func (e *ExtensionArrayBase) String() string

type ExtensionBuilder 

type ExtensionBuilder struct {
	Builder
	// contains filtered or unexported fields
}

ExtensionBuilder is a convenience builder so that NewBuilder and such will still work with extension types properly. Depending on preference it may be cleaner or easier to just use NewExtensionArrayWithStorage and pass a storage array.

That said, this allows easily building an extension array by providing the extension type and retrieving the storage builder.

func NewExtensionBuilder 

func NewExtensionBuilder(mem memory.Allocator, dt arrow.ExtensionType) *ExtensionBuilder

NewExtensionBuilder returns a builder using the provided memory allocator for the desired extension type. It will internally construct a builder of the storage type for the extension type and keep a copy of the extension type. The underlying type builder can then be retrieved by calling `StorageBuilder` on this and then type asserting it to the desired builder type.

After using the storage builder, calling NewArray or NewExtensionArray will construct the appropriate extension array type and set the storage correctly, resetting the builder for reuse.

Example

Simple example assuming an extension type of a UUID defined as a FixedSizeBinary(16) was registered using the type name "uuid": 

uuidType := arrow.GetExtensionType("uuid")
bldr := array.NewExtensionBuilder(memory.DefaultAllocator, uuidType)
defer bldr.Release()
uuidBldr := bldr.StorageBuilder().(*array.FixedSizeBinaryBuilder)
/* build up the fixed size binary array as usual via Append/AppendValues */
uuidArr := bldr.NewExtensionArray()
defer uuidArr.Release()

Because the storage builder is embedded in the Extension builder it also means that any of the functions available on the Builder interface can be called on an instance of ExtensionBuilder and will respond appropriately as the storage builder would for generically grabbing the Lenth, Cap, Nulls, reserving, etc.

func (*ExtensionBuilder) NewArray 

func (b *ExtensionBuilder) NewArray() arrow.Array

NewArray creates a new array from the memory buffers used by the builder and resets the builder so it can be used to build a new array.

func (*ExtensionBuilder) NewExtensionArray 

func (b *ExtensionBuilder) NewExtensionArray() ExtensionArray

NewExtensionArray creates an Extension array from the memory buffers used by the builder and resets the ExtensionBuilder so it can be used to build a new ExtensionArray of the same type.

func (*ExtensionBuilder) StorageBuilder 

func (b *ExtensionBuilder) StorageBuilder() Builder

StorageBuilder returns the builder for the underlying storage type.

type FixedSizeBinary 

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

A type which represents an immutable sequence of fixed-length binary strings.

func NewFixedSizeBinaryData 

func NewFixedSizeBinaryData(data arrow.ArrayData) *FixedSizeBinary

NewFixedSizeBinaryData constructs a new fixed-size binary array from data.

func (*FixedSizeBinary) Data 

func (a *FixedSizeBinary) Data() arrow.ArrayData

func (*FixedSizeBinary) DataType 

func (a *FixedSizeBinary) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*FixedSizeBinary) IsNull 

func (a *FixedSizeBinary) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*FixedSizeBinary) IsValid 

func (a *FixedSizeBinary) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*FixedSizeBinary) Len 

func (a *FixedSizeBinary) Len() int

Len returns the number of elements in the array.

func (*FixedSizeBinary) MarshalJSON 

func (a *FixedSizeBinary) MarshalJSON() ([]byte, error)

func (*FixedSizeBinary) NullBitmapBytes 

func (a *FixedSizeBinary) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*FixedSizeBinary) NullN 

func (a *FixedSizeBinary) NullN() int

NullN returns the number of null values in the array.

func (*FixedSizeBinary) Offset 

func (a *FixedSizeBinary) Offset() int

func (*FixedSizeBinary) Release 

func (a *FixedSizeBinary) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*FixedSizeBinary) Retain 

func (a *FixedSizeBinary) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*FixedSizeBinary) String 

func (a *FixedSizeBinary) String() string

func (*FixedSizeBinary) Value 

func (a *FixedSizeBinary) Value(i int) []byte

Value returns the fixed-size slice at index i. This value should not be mutated.

type FixedSizeBinaryBuilder 

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

A FixedSizeBinaryBuilder is used to build a FixedSizeBinary array using the Append methods.

func NewFixedSizeBinaryBuilder 

func NewFixedSizeBinaryBuilder(mem memory.Allocator, dtype *arrow.FixedSizeBinaryType) *FixedSizeBinaryBuilder

func (*FixedSizeBinaryBuilder) Append 

func (b *FixedSizeBinaryBuilder) Append(v []byte)

func (*FixedSizeBinaryBuilder) AppendNull 

func (b *FixedSizeBinaryBuilder) AppendNull()

func (*FixedSizeBinaryBuilder) AppendValues 

func (b *FixedSizeBinaryBuilder) AppendValues(v [][]byte, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*FixedSizeBinaryBuilder) Cap 

func (b *FixedSizeBinaryBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*FixedSizeBinaryBuilder) Len 

func (b *FixedSizeBinaryBuilder) Len() int

Len returns the number of elements in the array builder.

func (*FixedSizeBinaryBuilder) NewArray 

func (b *FixedSizeBinaryBuilder) NewArray() arrow.Array

NewArray creates a FixedSizeBinary array from the memory buffers used by the builder and resets the FixedSizeBinaryBuilder so it can be used to build a new array.

func (*FixedSizeBinaryBuilder) NewFixedSizeBinaryArray 

func (b *FixedSizeBinaryBuilder) NewFixedSizeBinaryArray() (a *FixedSizeBinary)

NewFixedSizeBinaryArray creates a FixedSizeBinary array from the memory buffers used by the builder and resets the FixedSizeBinaryBuilder so it can be used to build a new array.

func (*FixedSizeBinaryBuilder) NullN 

func (b *FixedSizeBinaryBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*FixedSizeBinaryBuilder) Release 

func (b *FixedSizeBinaryBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed. Release may be called simultaneously from multiple goroutines.

func (*FixedSizeBinaryBuilder) Reserve 

func (b *FixedSizeBinaryBuilder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*FixedSizeBinaryBuilder) Resize 

func (b *FixedSizeBinaryBuilder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*FixedSizeBinaryBuilder) Retain 

func (b *FixedSizeBinaryBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*FixedSizeBinaryBuilder) UnmarshalJSON 

func (b *FixedSizeBinaryBuilder) UnmarshalJSON(data []byte) error

func (*FixedSizeBinaryBuilder) UnsafeAppendBoolToBitmap 

func (b *FixedSizeBinaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)

type FixedSizeBinaryDictionaryBuilder 

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

func (*FixedSizeBinaryDictionaryBuilder) Append 

func (b *FixedSizeBinaryDictionaryBuilder) Append(v []byte) error

func (*FixedSizeBinaryDictionaryBuilder) AppendArray 

func (b *FixedSizeBinaryDictionaryBuilder) AppendArray(arr arrow.Array) error

func (*FixedSizeBinaryDictionaryBuilder) AppendNull 

func (b *FixedSizeBinaryDictionaryBuilder) AppendNull()

func (*FixedSizeBinaryDictionaryBuilder) Cap 

func (b *FixedSizeBinaryDictionaryBuilder) Cap() int

func (*FixedSizeBinaryDictionaryBuilder) InsertDictValues 

func (b *FixedSizeBinaryDictionaryBuilder) InsertDictValues(arr *FixedSizeBinary) (err error)

func (*FixedSizeBinaryDictionaryBuilder) NewArray 

func (b *FixedSizeBinaryDictionaryBuilder) NewArray() arrow.Array

func (*FixedSizeBinaryDictionaryBuilder) NewDelta 

func (b *FixedSizeBinaryDictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*FixedSizeBinaryDictionaryBuilder) NewDictionaryArray 

func (b *FixedSizeBinaryDictionaryBuilder) NewDictionaryArray() *Dictionary

func (*FixedSizeBinaryDictionaryBuilder) Release 

func (b *FixedSizeBinaryDictionaryBuilder) Release()

func (*FixedSizeBinaryDictionaryBuilder) Reserve 

func (b *FixedSizeBinaryDictionaryBuilder) Reserve(n int)

func (*FixedSizeBinaryDictionaryBuilder) ResetFull 

func (b *FixedSizeBinaryDictionaryBuilder) ResetFull()

func (*FixedSizeBinaryDictionaryBuilder) Resize 

func (b *FixedSizeBinaryDictionaryBuilder) Resize(n int)

func (*FixedSizeBinaryDictionaryBuilder) UnmarshalJSON 

func (b *FixedSizeBinaryDictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type FixedSizeList 

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

FixedSizeList represents an immutable sequence of N array values.

func NewFixedSizeListData 

func NewFixedSizeListData(data arrow.ArrayData) *FixedSizeList

NewFixedSizeListData returns a new List array value, from data.

func (*FixedSizeList) Data 

func (a *FixedSizeList) Data() arrow.ArrayData

func (*FixedSizeList) DataType 

func (a *FixedSizeList) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*FixedSizeList) IsNull 

func (a *FixedSizeList) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*FixedSizeList) IsValid 

func (a *FixedSizeList) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*FixedSizeList) Len 

func (a *FixedSizeList) Len() int

Len returns the number of elements in the array.

func (*FixedSizeList) ListValues 

func (a *FixedSizeList) ListValues() arrow.Array

func (*FixedSizeList) MarshalJSON 

func (a *FixedSizeList) MarshalJSON() ([]byte, error)

func (*FixedSizeList) NullBitmapBytes 

func (a *FixedSizeList) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*FixedSizeList) NullN 

func (a *FixedSizeList) NullN() int

NullN returns the number of null values in the array.

func (*FixedSizeList) Offset 

func (a *FixedSizeList) Offset() int

func (*FixedSizeList) Release 

func (a *FixedSizeList) Release()

func (*FixedSizeList) Retain 

func (a *FixedSizeList) Retain()

func (*FixedSizeList) String 

func (a *FixedSizeList) String() string

type FixedSizeListBuilder 

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

func NewFixedSizeListBuilder 

func NewFixedSizeListBuilder(mem memory.Allocator, n int32, etype arrow.DataType) *FixedSizeListBuilder

NewFixedSizeListBuilder returns a builder, using the provided memory allocator. The created list builder will create a list whose elements will be of type etype.

func (*FixedSizeListBuilder) Append 

func (b *FixedSizeListBuilder) Append(v bool)

func (*FixedSizeListBuilder) AppendNull 

func (b *FixedSizeListBuilder) AppendNull()

func (*FixedSizeListBuilder) AppendValues 

func (b *FixedSizeListBuilder) AppendValues(valid []bool)

func (*FixedSizeListBuilder) Cap 

func (b *FixedSizeListBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*FixedSizeListBuilder) Len 

func (b *FixedSizeListBuilder) Len() int

Len returns the number of elements in the array builder.

func (*FixedSizeListBuilder) NewArray 

func (b *FixedSizeListBuilder) NewArray() arrow.Array

NewArray creates a List array from the memory buffers used by the builder and resets the FixedSizeListBuilder so it can be used to build a new array.

func (*FixedSizeListBuilder) NewListArray 

func (b *FixedSizeListBuilder) NewListArray() (a *FixedSizeList)

NewListArray creates a List array from the memory buffers used by the builder and resets the FixedSizeListBuilder so it can be used to build a new array.

func (*FixedSizeListBuilder) NullN 

func (b *FixedSizeListBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*FixedSizeListBuilder) Release 

func (b *FixedSizeListBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*FixedSizeListBuilder) Reserve 

func (b *FixedSizeListBuilder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*FixedSizeListBuilder) Resize 

func (b *FixedSizeListBuilder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*FixedSizeListBuilder) Retain 

func (b *FixedSizeListBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*FixedSizeListBuilder) UnmarshalJSON 

func (b *FixedSizeListBuilder) UnmarshalJSON(data []byte) error

func (*FixedSizeListBuilder) UnsafeAppendBoolToBitmap 

func (b *FixedSizeListBuilder) UnsafeAppendBoolToBitmap(isValid bool)

func (*FixedSizeListBuilder) ValueBuilder 

func (b *FixedSizeListBuilder) ValueBuilder() Builder

type Float16 

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

A type which represents an immutable sequence of Float16 values.

func NewFloat16Data 

func NewFloat16Data(data arrow.ArrayData) *Float16

func (*Float16) Data 

func (a *Float16) Data() arrow.ArrayData

func (*Float16) DataType 

func (a *Float16) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Float16) IsNull 

func (a *Float16) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Float16) IsValid 

func (a *Float16) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Float16) Len 

func (a *Float16) Len() int

Len returns the number of elements in the array.

func (*Float16) MarshalJSON 

func (a *Float16) MarshalJSON() ([]byte, error)

func (*Float16) NullBitmapBytes 

func (a *Float16) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Float16) NullN 

func (a *Float16) NullN() int

NullN returns the number of null values in the array.

func (*Float16) Offset 

func (a *Float16) Offset() int

func (*Float16) Release 

func (a *Float16) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Float16) Retain 

func (a *Float16) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Float16) String 

func (a *Float16) String() string

func (*Float16) Value 

func (a *Float16) Value(i int) float16.Num

func (*Float16) Values 

func (a *Float16) Values() []float16.Num

type Float16Builder 

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

func NewFloat16Builder 

func NewFloat16Builder(mem memory.Allocator) *Float16Builder

func (*Float16Builder) Append 

func (b *Float16Builder) Append(v float16.Num)

func (*Float16Builder) AppendNull 

func (b *Float16Builder) AppendNull()

func (*Float16Builder) AppendValues 

func (b *Float16Builder) AppendValues(v []float16.Num, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Float16Builder) Cap 

func (b *Float16Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Float16Builder) Len 

func (b *Float16Builder) Len() int

Len returns the number of elements in the array builder.

func (*Float16Builder) NewArray 

func (b *Float16Builder) NewArray() arrow.Array

NewArray creates a Float16 array from the memory buffers used by the builder and resets the Float16Builder so it can be used to build a new array.

func (*Float16Builder) NewFloat16Array 

func (b *Float16Builder) NewFloat16Array() (a *Float16)

NewFloat16Array creates a Float16 array from the memory buffers used by the builder and resets the Float16Builder so it can be used to build a new array.

func (*Float16Builder) NullN 

func (b *Float16Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Float16Builder) Release 

func (b *Float16Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Float16Builder) Reserve 

func (b *Float16Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Float16Builder) Resize 

func (b *Float16Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Float16Builder) Retain 

func (b *Float16Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Float16Builder) UnmarshalJSON 

func (b *Float16Builder) UnmarshalJSON(data []byte) error

UnmarshalJSON will add values to this builder from unmarshalling the array of values. Currently values that are larger than a float16 will be silently truncated.

func (*Float16Builder) UnsafeAppend 

func (b *Float16Builder) UnsafeAppend(v float16.Num)

func (*Float16Builder) UnsafeAppendBoolToBitmap 

func (b *Float16Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Float16DictionaryBuilder 

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

func (*Float16DictionaryBuilder) Append 

func (b *Float16DictionaryBuilder) Append(v float16.Num) error

func (*Float16DictionaryBuilder) AppendArray 

func (b *Float16DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Float16DictionaryBuilder) AppendNull 

func (b *Float16DictionaryBuilder) AppendNull()

func (*Float16DictionaryBuilder) Cap 

func (b *Float16DictionaryBuilder) Cap() int

func (*Float16DictionaryBuilder) InsertDictValues 

func (b *Float16DictionaryBuilder) InsertDictValues(arr *Float16) (err error)

func (*Float16DictionaryBuilder) NewArray 

func (b *Float16DictionaryBuilder) NewArray() arrow.Array

func (*Float16DictionaryBuilder) NewDelta 

func (b *Float16DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Float16DictionaryBuilder) NewDictionaryArray 

func (b *Float16DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Float16DictionaryBuilder) Release 

func (b *Float16DictionaryBuilder) Release()

func (*Float16DictionaryBuilder) Reserve 

func (b *Float16DictionaryBuilder) Reserve(n int)

func (*Float16DictionaryBuilder) ResetFull 

func (b *Float16DictionaryBuilder) ResetFull()

func (*Float16DictionaryBuilder) Resize 

func (b *Float16DictionaryBuilder) Resize(n int)

func (*Float16DictionaryBuilder) UnmarshalJSON 

func (b *Float16DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Float32 

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

A type which represents an immutable sequence of float32 values.

func NewFloat32Data 

func NewFloat32Data(data arrow.ArrayData) *Float32

NewFloat32Data creates a new Float32.

func (*Float32) Data 

func (a *Float32) Data() arrow.ArrayData

func (*Float32) DataType 

func (a *Float32) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Float32) Float32Values 

func (a *Float32) Float32Values() []float32

Values returns the values.

func (*Float32) IsNull 

func (a *Float32) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Float32) IsValid 

func (a *Float32) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Float32) Len 

func (a *Float32) Len() int

Len returns the number of elements in the array.

func (*Float32) MarshalJSON 

func (a *Float32) MarshalJSON() ([]byte, error)

func (*Float32) NullBitmapBytes 

func (a *Float32) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Float32) NullN 

func (a *Float32) NullN() int

NullN returns the number of null values in the array.

func (*Float32) Offset 

func (a *Float32) Offset() int

func (*Float32) Release 

func (a *Float32) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Float32) Reset 

func (a *Float32) Reset(data *Data)

Reset resets the array for re-use.

func (*Float32) Retain 

func (a *Float32) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Float32) String 

func (a *Float32) String() string

String returns a string representation of the array.

func (*Float32) Value 

func (a *Float32) Value(i int) float32

Value returns the value at the specified index.

type Float32Builder 

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

func NewFloat32Builder 

func NewFloat32Builder(mem memory.Allocator) *Float32Builder

func (*Float32Builder) Append 

func (b *Float32Builder) Append(v float32)

func (*Float32Builder) AppendNull 

func (b *Float32Builder) AppendNull()

func (*Float32Builder) AppendValues 

func (b *Float32Builder) AppendValues(v []float32, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Float32Builder) Cap 

func (b *Float32Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Float32Builder) Len 

func (b *Float32Builder) Len() int

Len returns the number of elements in the array builder.

func (*Float32Builder) NewArray 

func (b *Float32Builder) NewArray() arrow.Array

NewArray creates a Float32 array from the memory buffers used by the builder and resets the Float32Builder so it can be used to build a new array.

func (*Float32Builder) NewFloat32Array 

func (b *Float32Builder) NewFloat32Array() (a *Float32)

NewFloat32Array creates a Float32 array from the memory buffers used by the builder and resets the Float32Builder so it can be used to build a new array.

func (*Float32Builder) NullN 

func (b *Float32Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Float32Builder) Release 

func (b *Float32Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Float32Builder) Reserve 

func (b *Float32Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Float32Builder) Resize 

func (b *Float32Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Float32Builder) Retain 

func (b *Float32Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Float32Builder) UnmarshalJSON 

func (b *Float32Builder) UnmarshalJSON(data []byte) error

func (*Float32Builder) UnsafeAppend 

func (b *Float32Builder) UnsafeAppend(v float32)

func (*Float32Builder) UnsafeAppendBoolToBitmap 

func (b *Float32Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Float32DictionaryBuilder 

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

func (*Float32DictionaryBuilder) Append 

func (b *Float32DictionaryBuilder) Append(v float32) error

func (*Float32DictionaryBuilder) AppendArray 

func (b *Float32DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Float32DictionaryBuilder) AppendNull 

func (b *Float32DictionaryBuilder) AppendNull()

func (*Float32DictionaryBuilder) Cap 

func (b *Float32DictionaryBuilder) Cap() int

func (*Float32DictionaryBuilder) InsertDictValues 

func (b *Float32DictionaryBuilder) InsertDictValues(arr *Float32) (err error)

func (*Float32DictionaryBuilder) NewArray 

func (b *Float32DictionaryBuilder) NewArray() arrow.Array

func (*Float32DictionaryBuilder) NewDelta 

func (b *Float32DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Float32DictionaryBuilder) NewDictionaryArray 

func (b *Float32DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Float32DictionaryBuilder) Release 

func (b *Float32DictionaryBuilder) Release()

func (*Float32DictionaryBuilder) Reserve 

func (b *Float32DictionaryBuilder) Reserve(n int)

func (*Float32DictionaryBuilder) ResetFull 

func (b *Float32DictionaryBuilder) ResetFull()

func (*Float32DictionaryBuilder) Resize 

func (b *Float32DictionaryBuilder) Resize(n int)

func (*Float32DictionaryBuilder) UnmarshalJSON 

func (b *Float32DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Float64 

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

A type which represents an immutable sequence of float64 values.

func NewFloat64Data 

func NewFloat64Data(data arrow.ArrayData) *Float64

NewFloat64Data creates a new Float64.

func (*Float64) Data 

func (a *Float64) Data() arrow.ArrayData

func (*Float64) DataType 

func (a *Float64) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Float64) Float64Values 

func (a *Float64) Float64Values() []float64

Values returns the values.

func (*Float64) IsNull 

func (a *Float64) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Float64) IsValid 

func (a *Float64) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Float64) Len 

func (a *Float64) Len() int

Len returns the number of elements in the array.

func (*Float64) MarshalJSON 

func (a *Float64) MarshalJSON() ([]byte, error)

func (*Float64) NullBitmapBytes 

func (a *Float64) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Float64) NullN 

func (a *Float64) NullN() int

NullN returns the number of null values in the array.

func (*Float64) Offset 

func (a *Float64) Offset() int

func (*Float64) Release 

func (a *Float64) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Float64) Reset 

func (a *Float64) Reset(data *Data)

Reset resets the array for re-use.

func (*Float64) Retain 

func (a *Float64) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Float64) String 

func (a *Float64) String() string

String returns a string representation of the array.

func (*Float64) Value 

func (a *Float64) Value(i int) float64

Value returns the value at the specified index.

type Float64Builder 

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

func NewFloat64Builder 

func NewFloat64Builder(mem memory.Allocator) *Float64Builder

func (*Float64Builder) Append 

func (b *Float64Builder) Append(v float64)

func (*Float64Builder) AppendNull 

func (b *Float64Builder) AppendNull()

func (*Float64Builder) AppendValues 

func (b *Float64Builder) AppendValues(v []float64, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Float64Builder) Cap 

func (b *Float64Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Float64Builder) Len 

func (b *Float64Builder) Len() int

Len returns the number of elements in the array builder.

func (*Float64Builder) NewArray 

func (b *Float64Builder) NewArray() arrow.Array

NewArray creates a Float64 array from the memory buffers used by the builder and resets the Float64Builder so it can be used to build a new array.

func (*Float64Builder) NewFloat64Array 

func (b *Float64Builder) NewFloat64Array() (a *Float64)

NewFloat64Array creates a Float64 array from the memory buffers used by the builder and resets the Float64Builder so it can be used to build a new array.

func (*Float64Builder) NullN 

func (b *Float64Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Float64Builder) Release 

func (b *Float64Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Float64Builder) Reserve 

func (b *Float64Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Float64Builder) Resize 

func (b *Float64Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Float64Builder) Retain 

func (b *Float64Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Float64Builder) UnmarshalJSON 

func (b *Float64Builder) UnmarshalJSON(data []byte) error

func (*Float64Builder) UnsafeAppend 

func (b *Float64Builder) UnsafeAppend(v float64)

func (*Float64Builder) UnsafeAppendBoolToBitmap 

func (b *Float64Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Float64DictionaryBuilder 

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

func (*Float64DictionaryBuilder) Append 

func (b *Float64DictionaryBuilder) Append(v float64) error

func (*Float64DictionaryBuilder) AppendArray 

func (b *Float64DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Float64DictionaryBuilder) AppendNull 

func (b *Float64DictionaryBuilder) AppendNull()

func (*Float64DictionaryBuilder) Cap 

func (b *Float64DictionaryBuilder) Cap() int

func (*Float64DictionaryBuilder) InsertDictValues 

func (b *Float64DictionaryBuilder) InsertDictValues(arr *Float64) (err error)

func (*Float64DictionaryBuilder) NewArray 

func (b *Float64DictionaryBuilder) NewArray() arrow.Array

func (*Float64DictionaryBuilder) NewDelta 

func (b *Float64DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Float64DictionaryBuilder) NewDictionaryArray 

func (b *Float64DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Float64DictionaryBuilder) Release 

func (b *Float64DictionaryBuilder) Release()

func (*Float64DictionaryBuilder) Reserve 

func (b *Float64DictionaryBuilder) Reserve(n int)

func (*Float64DictionaryBuilder) ResetFull 

func (b *Float64DictionaryBuilder) ResetFull()

func (*Float64DictionaryBuilder) Resize 

func (b *Float64DictionaryBuilder) Resize(n int)

func (*Float64DictionaryBuilder) UnmarshalJSON 

func (b *Float64DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type FromJSONOption 

type FromJSONOption func(*fromJSONCfg)

func WithMultipleDocs 

func WithMultipleDocs() FromJSONOption

func WithStartOffset 

func WithStartOffset(off int64) FromJSONOption

WithStartOffset attempts to start decoding from the reader at the offset passed in. If using this option the reader must fulfill the io.ReadSeeker interface, or else an error will be returned.

It will call Seek(off, io.SeekStart) on the reader

func WithUseNumber 

func WithUseNumber() FromJSONOption

WithUseNumber enables the 'UseNumber' option on the json decoder, using the json.Number type instead of assuming float64 for numbers. This is critical if you have numbers that are larger than what can fit into the 53 bits of an IEEE float64 mantissa and want to preserve its value.

type Int16 

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

A type which represents an immutable sequence of int16 values.

func NewInt16Data 

func NewInt16Data(data arrow.ArrayData) *Int16

NewInt16Data creates a new Int16.

func (*Int16) Data 

func (a *Int16) Data() arrow.ArrayData

func (*Int16) DataType 

func (a *Int16) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Int16) Int16Values 

func (a *Int16) Int16Values() []int16

Values returns the values.

func (*Int16) IsNull 

func (a *Int16) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Int16) IsValid 

func (a *Int16) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Int16) Len 

func (a *Int16) Len() int

Len returns the number of elements in the array.

func (*Int16) MarshalJSON 

func (a *Int16) MarshalJSON() ([]byte, error)

func (*Int16) NullBitmapBytes 

func (a *Int16) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Int16) NullN 

func (a *Int16) NullN() int

NullN returns the number of null values in the array.

func (*Int16) Offset 

func (a *Int16) Offset() int

func (*Int16) Release 

func (a *Int16) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Int16) Reset 

func (a *Int16) Reset(data *Data)

Reset resets the array for re-use.

func (*Int16) Retain 

func (a *Int16) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Int16) String 

func (a *Int16) String() string

String returns a string representation of the array.

func (*Int16) Value 

func (a *Int16) Value(i int) int16

Value returns the value at the specified index.

type Int16Builder 

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

func NewInt16Builder 

func NewInt16Builder(mem memory.Allocator) *Int16Builder

func (*Int16Builder) Append 

func (b *Int16Builder) Append(v int16)

func (*Int16Builder) AppendNull 

func (b *Int16Builder) AppendNull()

func (*Int16Builder) AppendValues 

func (b *Int16Builder) AppendValues(v []int16, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Int16Builder) Cap 

func (b *Int16Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Int16Builder) Len 

func (b *Int16Builder) Len() int

Len returns the number of elements in the array builder.

func (*Int16Builder) NewArray 

func (b *Int16Builder) NewArray() arrow.Array

NewArray creates a Int16 array from the memory buffers used by the builder and resets the Int16Builder so it can be used to build a new array.

func (*Int16Builder) NewInt16Array 

func (b *Int16Builder) NewInt16Array() (a *Int16)

NewInt16Array creates a Int16 array from the memory buffers used by the builder and resets the Int16Builder so it can be used to build a new array.

func (*Int16Builder) NullN 

func (b *Int16Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Int16Builder) Release 

func (b *Int16Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Int16Builder) Reserve 

func (b *Int16Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Int16Builder) Resize 

func (b *Int16Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Int16Builder) Retain 

func (b *Int16Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Int16Builder) UnmarshalJSON 

func (b *Int16Builder) UnmarshalJSON(data []byte) error

func (*Int16Builder) UnsafeAppend 

func (b *Int16Builder) UnsafeAppend(v int16)

func (*Int16Builder) UnsafeAppendBoolToBitmap 

func (b *Int16Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Int16DictionaryBuilder 

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

func (*Int16DictionaryBuilder) Append 

func (b *Int16DictionaryBuilder) Append(v int16) error

func (*Int16DictionaryBuilder) AppendArray 

func (b *Int16DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Int16DictionaryBuilder) AppendNull 

func (b *Int16DictionaryBuilder) AppendNull()

func (*Int16DictionaryBuilder) Cap 

func (b *Int16DictionaryBuilder) Cap() int

func (*Int16DictionaryBuilder) InsertDictValues 

func (b *Int16DictionaryBuilder) InsertDictValues(arr *Int16) (err error)

func (*Int16DictionaryBuilder) NewArray 

func (b *Int16DictionaryBuilder) NewArray() arrow.Array

func (*Int16DictionaryBuilder) NewDelta 

func (b *Int16DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Int16DictionaryBuilder) NewDictionaryArray 

func (b *Int16DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Int16DictionaryBuilder) Release 

func (b *Int16DictionaryBuilder) Release()

func (*Int16DictionaryBuilder) Reserve 

func (b *Int16DictionaryBuilder) Reserve(n int)

func (*Int16DictionaryBuilder) ResetFull 

func (b *Int16DictionaryBuilder) ResetFull()

func (*Int16DictionaryBuilder) Resize 

func (b *Int16DictionaryBuilder) Resize(n int)

func (*Int16DictionaryBuilder) UnmarshalJSON 

func (b *Int16DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Int32 

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

A type which represents an immutable sequence of int32 values.

func NewInt32Data 

func NewInt32Data(data arrow.ArrayData) *Int32

NewInt32Data creates a new Int32.

func (*Int32) Data 

func (a *Int32) Data() arrow.ArrayData

func (*Int32) DataType 

func (a *Int32) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Int32) Int32Values 

func (a *Int32) Int32Values() []int32

Values returns the values.

func (*Int32) IsNull 

func (a *Int32) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Int32) IsValid 

func (a *Int32) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Int32) Len 

func (a *Int32) Len() int

Len returns the number of elements in the array.

func (*Int32) MarshalJSON 

func (a *Int32) MarshalJSON() ([]byte, error)

func (*Int32) NullBitmapBytes 

func (a *Int32) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Int32) NullN 

func (a *Int32) NullN() int

NullN returns the number of null values in the array.

func (*Int32) Offset 

func (a *Int32) Offset() int

func (*Int32) Release 

func (a *Int32) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Int32) Reset 

func (a *Int32) Reset(data *Data)

Reset resets the array for re-use.

func (*Int32) Retain 

func (a *Int32) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Int32) String 

func (a *Int32) String() string

String returns a string representation of the array.

func (*Int32) Value 

func (a *Int32) Value(i int) int32

Value returns the value at the specified index.

type Int32Builder 

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

func NewInt32Builder 

func NewInt32Builder(mem memory.Allocator) *Int32Builder

func (*Int32Builder) Append 

func (b *Int32Builder) Append(v int32)

func (*Int32Builder) AppendNull 

func (b *Int32Builder) AppendNull()

func (*Int32Builder) AppendValues 

func (b *Int32Builder) AppendValues(v []int32, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Int32Builder) Cap 

func (b *Int32Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Int32Builder) Len 

func (b *Int32Builder) Len() int

Len returns the number of elements in the array builder.

func (*Int32Builder) NewArray 

func (b *Int32Builder) NewArray() arrow.Array

NewArray creates a Int32 array from the memory buffers used by the builder and resets the Int32Builder so it can be used to build a new array.

func (*Int32Builder) NewInt32Array 

func (b *Int32Builder) NewInt32Array() (a *Int32)

NewInt32Array creates a Int32 array from the memory buffers used by the builder and resets the Int32Builder so it can be used to build a new array.

func (*Int32Builder) NullN 

func (b *Int32Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Int32Builder) Release 

func (b *Int32Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Int32Builder) Reserve 

func (b *Int32Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Int32Builder) Resize 

func (b *Int32Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Int32Builder) Retain 

func (b *Int32Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Int32Builder) UnmarshalJSON 

func (b *Int32Builder) UnmarshalJSON(data []byte) error

func (*Int32Builder) UnsafeAppend 

func (b *Int32Builder) UnsafeAppend(v int32)

func (*Int32Builder) UnsafeAppendBoolToBitmap 

func (b *Int32Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Int32DictionaryBuilder 

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

func (*Int32DictionaryBuilder) Append 

func (b *Int32DictionaryBuilder) Append(v int32) error

func (*Int32DictionaryBuilder) AppendArray 

func (b *Int32DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Int32DictionaryBuilder) AppendNull 

func (b *Int32DictionaryBuilder) AppendNull()

func (*Int32DictionaryBuilder) Cap 

func (b *Int32DictionaryBuilder) Cap() int

func (*Int32DictionaryBuilder) InsertDictValues 

func (b *Int32DictionaryBuilder) InsertDictValues(arr *Int32) (err error)

func (*Int32DictionaryBuilder) NewArray 

func (b *Int32DictionaryBuilder) NewArray() arrow.Array

func (*Int32DictionaryBuilder) NewDelta 

func (b *Int32DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Int32DictionaryBuilder) NewDictionaryArray 

func (b *Int32DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Int32DictionaryBuilder) Release 

func (b *Int32DictionaryBuilder) Release()

func (*Int32DictionaryBuilder) Reserve 

func (b *Int32DictionaryBuilder) Reserve(n int)

func (*Int32DictionaryBuilder) ResetFull 

func (b *Int32DictionaryBuilder) ResetFull()

func (*Int32DictionaryBuilder) Resize 

func (b *Int32DictionaryBuilder) Resize(n int)

func (*Int32DictionaryBuilder) UnmarshalJSON 

func (b *Int32DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Int64 

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

A type which represents an immutable sequence of int64 values.

func NewInt64Data 

func NewInt64Data(data arrow.ArrayData) *Int64

NewInt64Data creates a new Int64.

func (*Int64) Data 

func (a *Int64) Data() arrow.ArrayData

func (*Int64) DataType 

func (a *Int64) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Int64) Int64Values 

func (a *Int64) Int64Values() []int64

Values returns the values.

func (*Int64) IsNull 

func (a *Int64) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Int64) IsValid 

func (a *Int64) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Int64) Len 

func (a *Int64) Len() int

Len returns the number of elements in the array.

func (*Int64) MarshalJSON 

func (a *Int64) MarshalJSON() ([]byte, error)

func (*Int64) NullBitmapBytes 

func (a *Int64) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Int64) NullN 

func (a *Int64) NullN() int

NullN returns the number of null values in the array.

func (*Int64) Offset 

func (a *Int64) Offset() int

func (*Int64) Release 

func (a *Int64) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Int64) Reset 

func (a *Int64) Reset(data *Data)

Reset resets the array for re-use.

func (*Int64) Retain 

func (a *Int64) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Int64) String 

func (a *Int64) String() string

String returns a string representation of the array.

func (*Int64) Value 

func (a *Int64) Value(i int) int64

Value returns the value at the specified index.

type Int64Builder 

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

func NewInt64Builder 

func NewInt64Builder(mem memory.Allocator) *Int64Builder

func (*Int64Builder) Append 

func (b *Int64Builder) Append(v int64)

func (*Int64Builder) AppendNull 

func (b *Int64Builder) AppendNull()

func (*Int64Builder) AppendValues 

func (b *Int64Builder) AppendValues(v []int64, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Int64Builder) Cap 

func (b *Int64Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Int64Builder) Len 

func (b *Int64Builder) Len() int

Len returns the number of elements in the array builder.

func (*Int64Builder) NewArray 

func (b *Int64Builder) NewArray() arrow.Array

NewArray creates a Int64 array from the memory buffers used by the builder and resets the Int64Builder so it can be used to build a new array.

func (*Int64Builder) NewInt64Array 

func (b *Int64Builder) NewInt64Array() (a *Int64)

NewInt64Array creates a Int64 array from the memory buffers used by the builder and resets the Int64Builder so it can be used to build a new array.

func (*Int64Builder) NullN 

func (b *Int64Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Int64Builder) Release 

func (b *Int64Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Int64Builder) Reserve 

func (b *Int64Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Int64Builder) Resize 

func (b *Int64Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Int64Builder) Retain 

func (b *Int64Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Int64Builder) UnmarshalJSON 

func (b *Int64Builder) UnmarshalJSON(data []byte) error

func (*Int64Builder) UnsafeAppend 

func (b *Int64Builder) UnsafeAppend(v int64)

func (*Int64Builder) UnsafeAppendBoolToBitmap 

func (b *Int64Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Int64DictionaryBuilder 

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

func (*Int64DictionaryBuilder) Append 

func (b *Int64DictionaryBuilder) Append(v int64) error

func (*Int64DictionaryBuilder) AppendArray 

func (b *Int64DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Int64DictionaryBuilder) AppendNull 

func (b *Int64DictionaryBuilder) AppendNull()

func (*Int64DictionaryBuilder) Cap 

func (b *Int64DictionaryBuilder) Cap() int

func (*Int64DictionaryBuilder) InsertDictValues 

func (b *Int64DictionaryBuilder) InsertDictValues(arr *Int64) (err error)

func (*Int64DictionaryBuilder) NewArray 

func (b *Int64DictionaryBuilder) NewArray() arrow.Array

func (*Int64DictionaryBuilder) NewDelta 

func (b *Int64DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Int64DictionaryBuilder) NewDictionaryArray 

func (b *Int64DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Int64DictionaryBuilder) Release 

func (b *Int64DictionaryBuilder) Release()

func (*Int64DictionaryBuilder) Reserve 

func (b *Int64DictionaryBuilder) Reserve(n int)

func (*Int64DictionaryBuilder) ResetFull 

func (b *Int64DictionaryBuilder) ResetFull()

func (*Int64DictionaryBuilder) Resize 

func (b *Int64DictionaryBuilder) Resize(n int)

func (*Int64DictionaryBuilder) UnmarshalJSON 

func (b *Int64DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Int8 

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

A type which represents an immutable sequence of int8 values.

func NewInt8Data 

func NewInt8Data(data arrow.ArrayData) *Int8

NewInt8Data creates a new Int8.

func (*Int8) Data 

func (a *Int8) Data() arrow.ArrayData

func (*Int8) DataType 

func (a *Int8) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Int8) Int8Values 

func (a *Int8) Int8Values() []int8

Values returns the values.

func (*Int8) IsNull 

func (a *Int8) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Int8) IsValid 

func (a *Int8) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Int8) Len 

func (a *Int8) Len() int

Len returns the number of elements in the array.

func (*Int8) MarshalJSON 

func (a *Int8) MarshalJSON() ([]byte, error)

func (*Int8) NullBitmapBytes 

func (a *Int8) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Int8) NullN 

func (a *Int8) NullN() int

NullN returns the number of null values in the array.

func (*Int8) Offset 

func (a *Int8) Offset() int

func (*Int8) Release 

func (a *Int8) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Int8) Reset 

func (a *Int8) Reset(data *Data)

Reset resets the array for re-use.

func (*Int8) Retain 

func (a *Int8) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Int8) String 

func (a *Int8) String() string

String returns a string representation of the array.

func (*Int8) Value 

func (a *Int8) Value(i int) int8

Value returns the value at the specified index.

type Int8Builder 

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

func NewInt8Builder 

func NewInt8Builder(mem memory.Allocator) *Int8Builder

func (*Int8Builder) Append 

func (b *Int8Builder) Append(v int8)

func (*Int8Builder) AppendNull 

func (b *Int8Builder) AppendNull()

func (*Int8Builder) AppendValues 

func (b *Int8Builder) AppendValues(v []int8, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Int8Builder) Cap 

func (b *Int8Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Int8Builder) Len 

func (b *Int8Builder) Len() int

Len returns the number of elements in the array builder.

func (*Int8Builder) NewArray 

func (b *Int8Builder) NewArray() arrow.Array

NewArray creates a Int8 array from the memory buffers used by the builder and resets the Int8Builder so it can be used to build a new array.

func (*Int8Builder) NewInt8Array 

func (b *Int8Builder) NewInt8Array() (a *Int8)

NewInt8Array creates a Int8 array from the memory buffers used by the builder and resets the Int8Builder so it can be used to build a new array.

func (*Int8Builder) NullN 

func (b *Int8Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Int8Builder) Release 

func (b *Int8Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Int8Builder) Reserve 

func (b *Int8Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Int8Builder) Resize 

func (b *Int8Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Int8Builder) Retain 

func (b *Int8Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Int8Builder) UnmarshalJSON 

func (b *Int8Builder) UnmarshalJSON(data []byte) error

func (*Int8Builder) UnsafeAppend 

func (b *Int8Builder) UnsafeAppend(v int8)

func (*Int8Builder) UnsafeAppendBoolToBitmap 

func (b *Int8Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Int8DictionaryBuilder 

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

func (*Int8DictionaryBuilder) Append 

func (b *Int8DictionaryBuilder) Append(v int8) error

func (*Int8DictionaryBuilder) AppendArray 

func (b *Int8DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Int8DictionaryBuilder) AppendNull 

func (b *Int8DictionaryBuilder) AppendNull()

func (*Int8DictionaryBuilder) Cap 

func (b *Int8DictionaryBuilder) Cap() int

func (*Int8DictionaryBuilder) InsertDictValues 

func (b *Int8DictionaryBuilder) InsertDictValues(arr *Int8) (err error)

func (*Int8DictionaryBuilder) NewArray 

func (b *Int8DictionaryBuilder) NewArray() arrow.Array

func (*Int8DictionaryBuilder) NewDelta 

func (b *Int8DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Int8DictionaryBuilder) NewDictionaryArray 

func (b *Int8DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Int8DictionaryBuilder) Release 

func (b *Int8DictionaryBuilder) Release()

func (*Int8DictionaryBuilder) Reserve 

func (b *Int8DictionaryBuilder) Reserve(n int)

func (*Int8DictionaryBuilder) ResetFull 

func (b *Int8DictionaryBuilder) ResetFull()

func (*Int8DictionaryBuilder) Resize 

func (b *Int8DictionaryBuilder) Resize(n int)

func (*Int8DictionaryBuilder) UnmarshalJSON 

func (b *Int8DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type JSONReader 

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

JSONReader is a json reader that meets the RecordReader interface definition.

To read in an array of objects as a record, you can use RecordFromJSON which is equivalent to reading the json as a struct array whose fields are the columns of the record. This primarily exists to fit the RecordReader interface as a matching reader for the csv reader.

func NewJSONReader 

func NewJSONReader(r io.Reader, schema *arrow.Schema, opts ...Option) *JSONReader

NewJSONReader returns a json RecordReader which expects to find one json object per row of dataset. Using WithChunk can control how many rows are processed per record, which is how many objects become a single record from the file.

If it is desired to write out an array of rows, then simply use RecordToStructArray and json.Marshal the struct array for the same effect.

func (*JSONReader) Err 

func (r *JSONReader) Err() error

Err returns the last encountered error

func (*JSONReader) Next 

func (r *JSONReader) Next() bool

Next returns true if it read in a record, which will be available via Record and false if there is either an error or the end of the reader.

func (*JSONReader) Record 

func (r *JSONReader) Record() arrow.Record

Record returns the last read in record. The returned record is only valid until the next call to Next unless Retain is called on the record itself.

func (*JSONReader) Release 

func (r *JSONReader) Release()

func (*JSONReader) Retain 

func (r *JSONReader) Retain()

func (*JSONReader) Schema 

func (r *JSONReader) Schema() *arrow.Schema

type List 

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

List represents an immutable sequence of array values.

func NewListData 

func NewListData(data arrow.ArrayData) *List

NewListData returns a new List array value, from data.

func (*List) Data 

func (a *List) Data() arrow.ArrayData

func (*List) DataType 

func (a *List) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*List) IsNull 

func (a *List) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*List) IsValid 

func (a *List) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*List) Len 

func (a *List) Len() int

Len returns the number of elements in the array.

func (*List) ListValues 

func (a *List) ListValues() arrow.Array

func (*List) MarshalJSON 

func (a *List) MarshalJSON() ([]byte, error)

func (*List) NullBitmapBytes 

func (a *List) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*List) NullN 

func (a *List) NullN() int

NullN returns the number of null values in the array.

func (*List) Offset 

func (a *List) Offset() int

func (*List) Offsets 

func (a *List) Offsets() []int32

func (*List) Release 

func (a *List) Release()

func (*List) Retain 

func (a *List) Retain()

func (*List) String 

func (a *List) String() string

type ListBuilder 

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

func NewListBuilder 

func NewListBuilder(mem memory.Allocator, etype arrow.DataType) *ListBuilder

NewListBuilder returns a builder, using the provided memory allocator. The created list builder will create a list whose elements will be of type etype.

func (*ListBuilder) Append 

func (b *ListBuilder) Append(v bool)

func (*ListBuilder) AppendNull 

func (b *ListBuilder) AppendNull()

func (*ListBuilder) AppendValues 

func (b *ListBuilder) AppendValues(offsets []int32, valid []bool)

func (*ListBuilder) Cap 

func (b *ListBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*ListBuilder) Len 

func (b *ListBuilder) Len() int

Len returns the number of elements in the array builder.

func (*ListBuilder) NewArray 

func (b *ListBuilder) NewArray() arrow.Array

NewArray creates a List array from the memory buffers used by the builder and resets the ListBuilder so it can be used to build a new array.

func (*ListBuilder) NewListArray 

func (b *ListBuilder) NewListArray() (a *List)

NewListArray creates a List array from the memory buffers used by the builder and resets the ListBuilder so it can be used to build a new array.

func (*ListBuilder) NullN 

func (b *ListBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*ListBuilder) Release 

func (b *ListBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*ListBuilder) Reserve 

func (b *ListBuilder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*ListBuilder) Resize 

func (b *ListBuilder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*ListBuilder) Retain 

func (b *ListBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*ListBuilder) UnmarshalJSON 

func (b *ListBuilder) UnmarshalJSON(data []byte) error

func (*ListBuilder) UnsafeAppendBoolToBitmap 

func (b *ListBuilder) UnsafeAppendBoolToBitmap(isValid bool)

func (*ListBuilder) ValueBuilder 

func (b *ListBuilder) ValueBuilder() Builder

type Map 

type Map struct {
	*List
	// contains filtered or unexported fields
}

Map represents an immutable sequence of Key/Value structs. It is a logical type that is implemented as a List<Struct: key, value>.

func NewMapData 

func NewMapData(data arrow.ArrayData) *Map

NewMapData returns a new Map array value, from data

func (Map) Data 

func (a Map) Data() arrow.ArrayData

func (Map) DataType 

func (a Map) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (Map) IsNull 

func (a Map) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (Map) IsValid 

func (a Map) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Map) Items 

func (a *Map) Items() arrow.Array

Items returns the full Array of Item values, equivalent to grabbing the Value field (the second field) of the child struct.

func (*Map) Keys 

func (a *Map) Keys() arrow.Array

Keys returns the full Array of Key values, equivalent to grabbing the key field of the child struct.

func (*Map) KeysSorted 

func (a *Map) KeysSorted() bool

KeysSorted checks the datatype that was used to construct this array and returns the KeysSorted boolean value used to denote if the key array is sorted for each list element.

Important note: Nothing is enforced regarding the KeysSorted value, it is solely a metadata field that should be set if keys within each value are sorted. This value is not used at all in regards to comparisons / equality.

func (Map) NullBitmapBytes 

func (a Map) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (Map) NullN 

func (a Map) NullN() int

NullN returns the number of null values in the array.

func (Map) Offset 

func (a Map) Offset() int

func (*Map) Release 

func (a *Map) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Map) Retain 

func (a *Map) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

type MapBuilder 

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

func NewMapBuilder 

func NewMapBuilder(mem memory.Allocator, keytype, itemtype arrow.DataType, keysSorted bool) *MapBuilder

NewMapBuilder returns a builder, using the provided memory allocator. The created Map builder will create a map array whose keys will be a non-nullable array of type `keytype` and whose mapped items will be a nullable array of itemtype.

KeysSorted is not enforced at all by the builder, it should only be set to true building using keys in sorted order for each value. The KeysSorted value will just be used when creating the DataType for the map.

Example

Simple example provided of converting a []map[string]int32 to an array.Map by using a MapBuilder: 

/* assume maplist == []map[string]int32 */
bldr := array.NewMapBuilder(memory.DefaultAllocator, arrow.BinaryTypes.String, arrow.PrimitiveTypes.Int32, false)
defer bldr.Release()
kb := bldr.KeyBuilder().(*array.StringBuilder)
ib := bldr.ItemBuilder().(*array.Int32Builder)
for _, m := range maplist {
    bldr.Append(true)
    for k, v := range m {
         kb.Append(k)
         ib.Append(v)
    }
}
maparr := bldr.NewMapArray()
defer maparr.Release()

func (*MapBuilder) Append 

func (b *MapBuilder) Append(v bool)

Append adds a new Map element to the array, calling Append(false) is equivalent to calling AppendNull.

func (*MapBuilder) AppendNull 

func (b *MapBuilder) AppendNull()

AppendNull adds a null map entry to the array.

func (*MapBuilder) AppendValues 

func (b *MapBuilder) AppendValues(offsets []int32, valid []bool)

AppendValues is for bulk appending a group of elements with offsets provided and validity booleans provided.

func (*MapBuilder) Cap 

func (b *MapBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*MapBuilder) ItemBuilder 

func (b *MapBuilder) ItemBuilder() Builder

ItemBuilder returns a builder that can be used to populate the values that the keys point to.

func (*MapBuilder) KeyBuilder 

func (b *MapBuilder) KeyBuilder() Builder

KeyBuilder returns a builder that can be used to populate the keys of the maps.

func (*MapBuilder) Len 

func (b *MapBuilder) Len() int

Len returns the current number of Maps that are in the builder

func (*MapBuilder) NewArray 

func (b *MapBuilder) NewArray() arrow.Array

NewArray creates a new Map array from the memory buffers used by the builder, and resets the builder so it can be used again to build a new Map array.

func (*MapBuilder) NewMapArray 

func (b *MapBuilder) NewMapArray() (a *Map)

NewMapArray creates a new Map array from the memory buffers used by the builder, and resets the builder so it can be used again to build a new Map array.

func (*MapBuilder) NullN 

func (b *MapBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*MapBuilder) Release 

func (b *MapBuilder) Release()

Release decreases the reference count by 1 for the sub builders (list, key, item).

func (*MapBuilder) Reserve 

func (b *MapBuilder) Reserve(n int)

Reserve enough space for n maps

func (*MapBuilder) Resize 

func (b *MapBuilder) Resize(n int)

Resize adjust the space allocated by b to n map elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may be reduced.

func (*MapBuilder) Retain 

func (b *MapBuilder) Retain()

Retain increases the reference count by 1 for the sub-builders (list, key, item). Retain may be called simultaneously from multiple goroutines.

func (*MapBuilder) UnmarshalJSON 

func (b *MapBuilder) UnmarshalJSON(data []byte) error

func (*MapBuilder) ValueBuilder 

func (b *MapBuilder) ValueBuilder() *StructBuilder

ValueBuilder can be used instead of separately using the Key/Item builders to build the list as a List of Structs rather than building the keys/items separately.

type MonthDayNanoDictionaryBuilder 

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

func (*MonthDayNanoDictionaryBuilder) Append 

func (b *MonthDayNanoDictionaryBuilder) Append(v arrow.MonthDayNanoInterval) error

func (*MonthDayNanoDictionaryBuilder) AppendArray 

func (b *MonthDayNanoDictionaryBuilder) AppendArray(arr arrow.Array) error

func (*MonthDayNanoDictionaryBuilder) AppendNull 

func (b *MonthDayNanoDictionaryBuilder) AppendNull()

func (*MonthDayNanoDictionaryBuilder) Cap 

func (b *MonthDayNanoDictionaryBuilder) Cap() int

func (*MonthDayNanoDictionaryBuilder) InsertDictValues 

func (b *MonthDayNanoDictionaryBuilder) InsertDictValues(arr *MonthDayNanoInterval) (err error)

func (*MonthDayNanoDictionaryBuilder) NewArray 

func (b *MonthDayNanoDictionaryBuilder) NewArray() arrow.Array

func (*MonthDayNanoDictionaryBuilder) NewDelta 

func (b *MonthDayNanoDictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*MonthDayNanoDictionaryBuilder) NewDictionaryArray 

func (b *MonthDayNanoDictionaryBuilder) NewDictionaryArray() *Dictionary

func (*MonthDayNanoDictionaryBuilder) Release 

func (b *MonthDayNanoDictionaryBuilder) Release()

func (*MonthDayNanoDictionaryBuilder) Reserve 

func (b *MonthDayNanoDictionaryBuilder) Reserve(n int)

func (*MonthDayNanoDictionaryBuilder) ResetFull 

func (b *MonthDayNanoDictionaryBuilder) ResetFull()

func (*MonthDayNanoDictionaryBuilder) Resize 

func (b *MonthDayNanoDictionaryBuilder) Resize(n int)

func (*MonthDayNanoDictionaryBuilder) UnmarshalJSON 

func (b *MonthDayNanoDictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type MonthDayNanoInterval 

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

A type which represents an immutable sequence of arrow.DayTimeInterval values.

func NewMonthDayNanoIntervalData 

func NewMonthDayNanoIntervalData(data arrow.ArrayData) *MonthDayNanoInterval

func (*MonthDayNanoInterval) Data 

func (a *MonthDayNanoInterval) Data() arrow.ArrayData

func (*MonthDayNanoInterval) DataType 

func (a *MonthDayNanoInterval) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*MonthDayNanoInterval) IsNull 

func (a *MonthDayNanoInterval) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*MonthDayNanoInterval) IsValid 

func (a *MonthDayNanoInterval) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*MonthDayNanoInterval) Len 

func (a *MonthDayNanoInterval) Len() int

Len returns the number of elements in the array.

func (*MonthDayNanoInterval) MarshalJSON 

func (a *MonthDayNanoInterval) MarshalJSON() ([]byte, error)

MarshalJSON will marshal this array to a JSON array with elements marshalled to the form {"months": #, "days": #, "nanoseconds": #}

func (*MonthDayNanoInterval) MonthDayNanoIntervalValues 

func (a *MonthDayNanoInterval) MonthDayNanoIntervalValues() []arrow.MonthDayNanoInterval

func (*MonthDayNanoInterval) NullBitmapBytes 

func (a *MonthDayNanoInterval) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*MonthDayNanoInterval) NullN 

func (a *MonthDayNanoInterval) NullN() int

NullN returns the number of null values in the array.

func (*MonthDayNanoInterval) Offset 

func (a *MonthDayNanoInterval) Offset() int

func (*MonthDayNanoInterval) Release 

func (a *MonthDayNanoInterval) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*MonthDayNanoInterval) Retain 

func (a *MonthDayNanoInterval) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*MonthDayNanoInterval) String 

func (a *MonthDayNanoInterval) String() string

func (*MonthDayNanoInterval) Value 

func (a *MonthDayNanoInterval) Value(i int) arrow.MonthDayNanoInterval

type MonthDayNanoIntervalBuilder 

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

func NewMonthDayNanoIntervalBuilder 

func NewMonthDayNanoIntervalBuilder(mem memory.Allocator) *MonthDayNanoIntervalBuilder

func (*MonthDayNanoIntervalBuilder) Append 

func (b *MonthDayNanoIntervalBuilder) Append(v arrow.MonthDayNanoInterval)

func (*MonthDayNanoIntervalBuilder) AppendNull 

func (b *MonthDayNanoIntervalBuilder) AppendNull()

func (*MonthDayNanoIntervalBuilder) AppendValues 

func (b *MonthDayNanoIntervalBuilder) AppendValues(v []arrow.MonthDayNanoInterval, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*MonthDayNanoIntervalBuilder) Cap 

func (b *MonthDayNanoIntervalBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*MonthDayNanoIntervalBuilder) Len 

func (b *MonthDayNanoIntervalBuilder) Len() int

Len returns the number of elements in the array builder.

func (*MonthDayNanoIntervalBuilder) NewArray 

func (b *MonthDayNanoIntervalBuilder) NewArray() arrow.Array

NewArray creates a MonthDayNanoInterval array from the memory buffers used by the builder and resets the MonthDayNanoIntervalBuilder so it can be used to build a new array.

func (*MonthDayNanoIntervalBuilder) NewMonthDayNanoIntervalArray 

func (b *MonthDayNanoIntervalBuilder) NewMonthDayNanoIntervalArray() (a *MonthDayNanoInterval)

NewMonthDayNanoIntervalArray creates a MonthDayNanoInterval array from the memory buffers used by the builder and resets the MonthDayNanoIntervalBuilder so it can be used to build a new array.

func (*MonthDayNanoIntervalBuilder) NullN 

func (b *MonthDayNanoIntervalBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*MonthDayNanoIntervalBuilder) Release 

func (b *MonthDayNanoIntervalBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*MonthDayNanoIntervalBuilder) Reserve 

func (b *MonthDayNanoIntervalBuilder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*MonthDayNanoIntervalBuilder) Resize 

func (b *MonthDayNanoIntervalBuilder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*MonthDayNanoIntervalBuilder) Retain 

func (b *MonthDayNanoIntervalBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*MonthDayNanoIntervalBuilder) UnmarshalJSON 

func (b *MonthDayNanoIntervalBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshals a JSON array of objects and adds them to this builder, each element of the array is expected to be an object of the form {"months": #, "days": #, "nanoseconds": #}

func (*MonthDayNanoIntervalBuilder) UnsafeAppend 

func (b *MonthDayNanoIntervalBuilder) UnsafeAppend(v arrow.MonthDayNanoInterval)

func (*MonthDayNanoIntervalBuilder) UnsafeAppendBoolToBitmap 

func (b *MonthDayNanoIntervalBuilder) UnsafeAppendBoolToBitmap(isValid bool)

type MonthInterval 

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

A type which represents an immutable sequence of arrow.MonthInterval values.

func NewMonthIntervalData 

func NewMonthIntervalData(data arrow.ArrayData) *MonthInterval

func (*MonthInterval) Data 

func (a *MonthInterval) Data() arrow.ArrayData

func (*MonthInterval) DataType 

func (a *MonthInterval) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*MonthInterval) IsNull 

func (a *MonthInterval) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*MonthInterval) IsValid 

func (a *MonthInterval) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*MonthInterval) Len 

func (a *MonthInterval) Len() int

Len returns the number of elements in the array.

func (*MonthInterval) MarshalJSON 

func (a *MonthInterval) MarshalJSON() ([]byte, error)

MarshalJSON will create a json array out of a MonthInterval array, each value will be an object of the form {"months": #} where # is the numeric value of that index

func (*MonthInterval) MonthIntervalValues 

func (a *MonthInterval) MonthIntervalValues() []arrow.MonthInterval

func (*MonthInterval) NullBitmapBytes 

func (a *MonthInterval) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*MonthInterval) NullN 

func (a *MonthInterval) NullN() int

NullN returns the number of null values in the array.

func (*MonthInterval) Offset 

func (a *MonthInterval) Offset() int

func (*MonthInterval) Release 

func (a *MonthInterval) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*MonthInterval) Retain 

func (a *MonthInterval) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*MonthInterval) String 

func (a *MonthInterval) String() string

func (*MonthInterval) Value 

func (a *MonthInterval) Value(i int) arrow.MonthInterval

type MonthIntervalBuilder 

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

func NewMonthIntervalBuilder 

func NewMonthIntervalBuilder(mem memory.Allocator) *MonthIntervalBuilder

func (*MonthIntervalBuilder) Append 

func (b *MonthIntervalBuilder) Append(v arrow.MonthInterval)

func (*MonthIntervalBuilder) AppendNull 

func (b *MonthIntervalBuilder) AppendNull()

func (*MonthIntervalBuilder) AppendValues 

func (b *MonthIntervalBuilder) AppendValues(v []arrow.MonthInterval, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*MonthIntervalBuilder) Cap 

func (b *MonthIntervalBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*MonthIntervalBuilder) Len 

func (b *MonthIntervalBuilder) Len() int

Len returns the number of elements in the array builder.

func (*MonthIntervalBuilder) NewArray 

func (b *MonthIntervalBuilder) NewArray() arrow.Array

NewArray creates a MonthInterval array from the memory buffers used by the builder and resets the MonthIntervalBuilder so it can be used to build a new array.

func (*MonthIntervalBuilder) NewMonthIntervalArray 

func (b *MonthIntervalBuilder) NewMonthIntervalArray() (a *MonthInterval)

NewMonthIntervalArray creates a MonthInterval array from the memory buffers used by the builder and resets the MonthIntervalBuilder so it can be used to build a new array.

func (*MonthIntervalBuilder) NullN 

func (b *MonthIntervalBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*MonthIntervalBuilder) Release 

func (b *MonthIntervalBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*MonthIntervalBuilder) Reserve 

func (b *MonthIntervalBuilder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*MonthIntervalBuilder) Resize 

func (b *MonthIntervalBuilder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*MonthIntervalBuilder) Retain 

func (b *MonthIntervalBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*MonthIntervalBuilder) UnmarshalJSON 

func (b *MonthIntervalBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON will add the unmarshalled values of an array to the builder, values are expected to be strings of the form "#months" where # is the int32 value that will be added to the builder.

func (*MonthIntervalBuilder) UnsafeAppend 

func (b *MonthIntervalBuilder) UnsafeAppend(v arrow.MonthInterval)

func (*MonthIntervalBuilder) UnsafeAppendBoolToBitmap 

func (b *MonthIntervalBuilder) UnsafeAppendBoolToBitmap(isValid bool)

type MonthIntervalDictionaryBuilder 

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

func (*MonthIntervalDictionaryBuilder) Append 

func (b *MonthIntervalDictionaryBuilder) Append(v arrow.MonthInterval) error

func (*MonthIntervalDictionaryBuilder) AppendArray 

func (b *MonthIntervalDictionaryBuilder) AppendArray(arr arrow.Array) error

func (*MonthIntervalDictionaryBuilder) AppendNull 

func (b *MonthIntervalDictionaryBuilder) AppendNull()

func (*MonthIntervalDictionaryBuilder) Cap 

func (b *MonthIntervalDictionaryBuilder) Cap() int

func (*MonthIntervalDictionaryBuilder) InsertDictValues 

func (b *MonthIntervalDictionaryBuilder) InsertDictValues(arr *MonthInterval) (err error)

func (*MonthIntervalDictionaryBuilder) NewArray 

func (b *MonthIntervalDictionaryBuilder) NewArray() arrow.Array

func (*MonthIntervalDictionaryBuilder) NewDelta 

func (b *MonthIntervalDictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*MonthIntervalDictionaryBuilder) NewDictionaryArray 

func (b *MonthIntervalDictionaryBuilder) NewDictionaryArray() *Dictionary

func (*MonthIntervalDictionaryBuilder) Release 

func (b *MonthIntervalDictionaryBuilder) Release()

func (*MonthIntervalDictionaryBuilder) Reserve 

func (b *MonthIntervalDictionaryBuilder) Reserve(n int)

func (*MonthIntervalDictionaryBuilder) ResetFull 

func (b *MonthIntervalDictionaryBuilder) ResetFull()

func (*MonthIntervalDictionaryBuilder) Resize 

func (b *MonthIntervalDictionaryBuilder) Resize(n int)

func (*MonthIntervalDictionaryBuilder) UnmarshalJSON 

func (b *MonthIntervalDictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Null 

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

Null represents an immutable, degenerate array with no physical storage.

func NewNull 

func NewNull(n int) *Null

NewNull returns a new Null array value of size n.

func NewNullData 

func NewNullData(data arrow.ArrayData) *Null

NewNullData returns a new Null array value, from data.

func (*Null) Data 

func (a *Null) Data() arrow.ArrayData

func (*Null) DataType 

func (a *Null) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Null) IsNull 

func (a *Null) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Null) IsValid 

func (a *Null) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Null) Len 

func (a *Null) Len() int

Len returns the number of elements in the array.

func (*Null) MarshalJSON 

func (a *Null) MarshalJSON() ([]byte, error)

func (*Null) NullBitmapBytes 

func (a *Null) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Null) NullN 

func (a *Null) NullN() int

NullN returns the number of null values in the array.

func (*Null) Offset 

func (a *Null) Offset() int

func (*Null) Release 

func (a *Null) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Null) Retain 

func (a *Null) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Null) String 

func (a *Null) String() string

type NullBuilder 

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

func NewNullBuilder 

func NewNullBuilder(mem memory.Allocator) *NullBuilder

NewNullBuilder returns a builder, using the provided memory allocator.

func (*NullBuilder) AppendNull 

func (b *NullBuilder) AppendNull()

func (*NullBuilder) Cap 

func (b *NullBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*NullBuilder) Len 

func (b *NullBuilder) Len() int

Len returns the number of elements in the array builder.

func (*NullBuilder) NewArray 

func (b *NullBuilder) NewArray() arrow.Array

NewArray creates a Null array from the memory buffers used by the builder and resets the NullBuilder so it can be used to build a new array.

func (*NullBuilder) NewNullArray 

func (b *NullBuilder) NewNullArray() (a *Null)

NewNullArray creates a Null array from the memory buffers used by the builder and resets the NullBuilder so it can be used to build a new array.

func (*NullBuilder) NullN 

func (b *NullBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*NullBuilder) Release 

func (b *NullBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*NullBuilder) Reserve 

func (*NullBuilder) Reserve(size int)

func (*NullBuilder) Resize 

func (*NullBuilder) Resize(size int)

func (*NullBuilder) Retain 

func (b *NullBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*NullBuilder) UnmarshalJSON 

func (b *NullBuilder) UnmarshalJSON(data []byte) error

func (*NullBuilder) UnsafeAppendBoolToBitmap 

func (b *NullBuilder) UnsafeAppendBoolToBitmap(isValid bool)

type NullDictionaryBuilder 

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

func (*NullDictionaryBuilder) AppendArray 

func (b *NullDictionaryBuilder) AppendArray(arr arrow.Array) error

func (*NullDictionaryBuilder) AppendNull 

func (b *NullDictionaryBuilder) AppendNull()

func (*NullDictionaryBuilder) Cap 

func (b *NullDictionaryBuilder) Cap() int

func (*NullDictionaryBuilder) NewArray 

func (b *NullDictionaryBuilder) NewArray() arrow.Array

func (*NullDictionaryBuilder) NewDelta 

func (b *NullDictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*NullDictionaryBuilder) NewDictionaryArray 

func (b *NullDictionaryBuilder) NewDictionaryArray() *Dictionary

func (*NullDictionaryBuilder) Release 

func (b *NullDictionaryBuilder) Release()

func (*NullDictionaryBuilder) Reserve 

func (b *NullDictionaryBuilder) Reserve(n int)

func (*NullDictionaryBuilder) ResetFull 

func (b *NullDictionaryBuilder) ResetFull()

func (*NullDictionaryBuilder) Resize 

func (b *NullDictionaryBuilder) Resize(n int)

func (*NullDictionaryBuilder) UnmarshalJSON 

func (b *NullDictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Option 

type Option func(config)

func WithAllocator 

func WithAllocator(mem memory.Allocator) Option

WithAllocator specifies the allocator to use for creating the record batches, if it is not called, then memory.DefaultAllocator will be used.

func WithChunk 

func WithChunk(n int) Option

WithChunk sets the chunk size for reading in json records. The default is to read in one row per record batch as a single object. If chunk size is set to a negative value, then the entire file is read as a single record batch. Otherwise a record batch is read in with chunk size rows per record batch until it reaches EOF.

type RecordBuilder 

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

RecordBuilder eases the process of building a Record, iteratively, from a known Schema.

func NewRecordBuilder 

func NewRecordBuilder(mem memory.Allocator, schema *arrow.Schema) *RecordBuilder

NewRecordBuilder returns a builder, using the provided memory allocator and a schema.

func (*RecordBuilder) Field 

func (b *RecordBuilder) Field(i int) Builder

func (*RecordBuilder) Fields 

func (b *RecordBuilder) Fields() []Builder

func (*RecordBuilder) NewRecord 

func (b *RecordBuilder) NewRecord() arrow.Record

NewRecord creates a new record from the memory buffers and resets the RecordBuilder so it can be used to build a new record.

The returned Record must be Release()'d after use.

NewRecord panics if the fields' builder do not have the same length.

func (*RecordBuilder) Release 

func (b *RecordBuilder) Release()

Release decreases the reference count by 1.

func (*RecordBuilder) Reserve 

func (b *RecordBuilder) Reserve(size int)

func (*RecordBuilder) Retain 

func (b *RecordBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*RecordBuilder) Schema 

func (b *RecordBuilder) Schema() *arrow.Schema

func (*RecordBuilder) UnmarshalJSON 

func (b *RecordBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON for record builder will read in a single object and add the values to each field in the recordbuilder, missing fields will get a null and unexpected keys will be ignored. If reading in an array of records as a single batch, then use a structbuilder and use RecordFromStruct.

type RecordReader 

type RecordReader interface {
	Retain()
	Release()

	Schema() *arrow.Schema

	Next() bool
	Record() arrow.Record
}

RecordReader reads a stream of records.

type String 

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

String represents an immutable sequence of variable-length UTF-8 strings.

func NewStringData 

func NewStringData(data arrow.ArrayData) *String

NewStringData constructs a new String array from data.

func (*String) Data 

func (a *String) Data() arrow.ArrayData

func (*String) DataType 

func (a *String) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*String) IsNull 

func (a *String) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*String) IsValid 

func (a *String) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*String) Len 

func (a *String) Len() int

Len returns the number of elements in the array.

func (*String) MarshalJSON 

func (a *String) MarshalJSON() ([]byte, error)

func (*String) NullBitmapBytes 

func (a *String) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*String) NullN 

func (a *String) NullN() int

NullN returns the number of null values in the array.

func (*String) Offset 

func (a *String) Offset() int

func (*String) Release 

func (a *String) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*String) Reset 

func (a *String) Reset(data arrow.ArrayData)

Reset resets the String with a different set of Data.

func (*String) Retain 

func (a *String) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*String) String 

func (a *String) String() string

func (*String) Value 

func (a *String) Value(i int) string

Value returns the slice at index i. This value should not be mutated.

func (*String) ValueBytes 

func (a *String) ValueBytes() (ret []byte)

func (*String) ValueOffset 

func (a *String) ValueOffset(i int) int

ValueOffset returns the offset of the value at index i.

func (*String) ValueOffsets 

func (a *String) ValueOffsets() []int32

type StringBuilder 

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

A StringBuilder is used to build a String array using the Append methods.

func NewStringBuilder 

func NewStringBuilder(mem memory.Allocator) *StringBuilder

NewStringBuilder creates a new StringBuilder.

func (*StringBuilder) Append 

func (b *StringBuilder) Append(v string)

Append appends a string to the builder.

func (*StringBuilder) AppendNull 

func (b *StringBuilder) AppendNull()

AppendNull appends a null to the builder.

func (*StringBuilder) AppendValues 

func (b *StringBuilder) AppendValues(v []string, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*StringBuilder) Cap 

func (b *StringBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*StringBuilder) Len 

func (b *StringBuilder) Len() int

Len returns the number of elements in the array builder.

func (*StringBuilder) NewArray 

func (b *StringBuilder) NewArray() arrow.Array

NewArray creates a String array from the memory buffers used by the builder and resets the StringBuilder so it can be used to build a new array.

func (*StringBuilder) NewStringArray 

func (b *StringBuilder) NewStringArray() (a *String)

NewStringArray creates a String array from the memory buffers used by the builder and resets the StringBuilder so it can be used to build a new array.

func (*StringBuilder) NullN 

func (b *StringBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*StringBuilder) Release 

func (b *StringBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed. Release may be called simultaneously from multiple goroutines.

func (*StringBuilder) Reserve 

func (b *StringBuilder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*StringBuilder) ReserveData 

func (b *StringBuilder) ReserveData(n int)

ReserveData ensures there is enough space for appending n bytes by checking the capacity and resizing the data buffer if necessary.

func (*StringBuilder) Resize 

func (b *StringBuilder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*StringBuilder) Retain 

func (b *StringBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*StringBuilder) UnmarshalJSON 

func (b *StringBuilder) UnmarshalJSON(data []byte) error

func (*StringBuilder) Value 

func (b *StringBuilder) Value(i int) string

Value returns the string at index i.

type Struct 

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

Struct represents an ordered sequence of relative types.

func NewStructData 

func NewStructData(data arrow.ArrayData) *Struct

NewStructData returns a new Struct array value from data.

func RecordToStructArray 

func RecordToStructArray(rec arrow.Record) *Struct

RecordToStructArray constructs a struct array from the columns of the record batch by referencing them, zero-copy.

func (*Struct) Data 

func (a *Struct) Data() arrow.ArrayData

func (*Struct) DataType 

func (a *Struct) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Struct) Field 

func (a *Struct) Field(i int) arrow.Array

func (*Struct) IsNull 

func (a *Struct) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Struct) IsValid 

func (a *Struct) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Struct) Len 

func (a *Struct) Len() int

Len returns the number of elements in the array.

func (*Struct) MarshalJSON 

func (a *Struct) MarshalJSON() ([]byte, error)

func (*Struct) NullBitmapBytes 

func (a *Struct) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Struct) NullN 

func (a *Struct) NullN() int

NullN returns the number of null values in the array.

func (*Struct) NumField 

func (a *Struct) NumField() int

func (*Struct) Offset 

func (a *Struct) Offset() int

func (*Struct) Release 

func (a *Struct) Release()

func (*Struct) Retain 

func (a *Struct) Retain()

func (*Struct) String 

func (a *Struct) String() string

type StructBuilder 

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

func NewStructBuilder 

func NewStructBuilder(mem memory.Allocator, dtype *arrow.StructType) *StructBuilder

NewStructBuilder returns a builder, using the provided memory allocator.

func (*StructBuilder) Append 

func (b *StructBuilder) Append(v bool)

func (*StructBuilder) AppendNull 

func (b *StructBuilder) AppendNull()

func (*StructBuilder) AppendValues 

func (b *StructBuilder) AppendValues(valids []bool)

func (*StructBuilder) Cap 

func (b *StructBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*StructBuilder) FieldBuilder 

func (b *StructBuilder) FieldBuilder(i int) Builder

func (*StructBuilder) Len 

func (b *StructBuilder) Len() int

Len returns the number of elements in the array builder.

func (*StructBuilder) NewArray 

func (b *StructBuilder) NewArray() arrow.Array

NewArray creates a Struct array from the memory buffers used by the builder and resets the StructBuilder so it can be used to build a new array.

func (*StructBuilder) NewStructArray 

func (b *StructBuilder) NewStructArray() (a *Struct)

NewStructArray creates a Struct array from the memory buffers used by the builder and resets the StructBuilder so it can be used to build a new array.

func (*StructBuilder) NullN 

func (b *StructBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*StructBuilder) NumField 

func (b *StructBuilder) NumField() int

func (*StructBuilder) Release 

func (b *StructBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*StructBuilder) Reserve 

func (b *StructBuilder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*StructBuilder) Resize 

func (b *StructBuilder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*StructBuilder) Retain 

func (b *StructBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*StructBuilder) UnmarshalJSON 

func (b *StructBuilder) UnmarshalJSON(data []byte) error

func (*StructBuilder) UnsafeAppendBoolToBitmap 

func (b *StructBuilder) UnsafeAppendBoolToBitmap(isValid bool)

type TableReader 

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

TableReader is a Record iterator over a (possibly chunked) Table

func NewTableReader 

func NewTableReader(tbl arrow.Table, chunkSize int64) *TableReader

NewTableReader returns a new TableReader to iterate over the (possibly chunked) Table. if chunkSize is <= 0, the biggest possible chunk will be selected.

func (*TableReader) Next 

func (tr *TableReader) Next() bool

func (*TableReader) Record 

func (tr *TableReader) Record() arrow.Record

func (*TableReader) Release 

func (tr *TableReader) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed. Release may be called simultaneously from multiple goroutines.

func (*TableReader) Retain 

func (tr *TableReader) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*TableReader) Schema 

func (tr *TableReader) Schema() *arrow.Schema

type Time32 

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

A type which represents an immutable sequence of arrow.Time32 values.

func NewTime32Data 

func NewTime32Data(data arrow.ArrayData) *Time32

NewTime32Data creates a new Time32.

func (*Time32) Data 

func (a *Time32) Data() arrow.ArrayData

func (*Time32) DataType 

func (a *Time32) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Time32) IsNull 

func (a *Time32) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Time32) IsValid 

func (a *Time32) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Time32) Len 

func (a *Time32) Len() int

Len returns the number of elements in the array.

func (*Time32) MarshalJSON 

func (a *Time32) MarshalJSON() ([]byte, error)

func (*Time32) NullBitmapBytes 

func (a *Time32) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Time32) NullN 

func (a *Time32) NullN() int

NullN returns the number of null values in the array.

func (*Time32) Offset 

func (a *Time32) Offset() int

func (*Time32) Release 

func (a *Time32) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Time32) Reset 

func (a *Time32) Reset(data *Data)

Reset resets the array for re-use.

func (*Time32) Retain 

func (a *Time32) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Time32) String 

func (a *Time32) String() string

String returns a string representation of the array.

func (*Time32) Time32Values 

func (a *Time32) Time32Values() []arrow.Time32

Values returns the values.

func (*Time32) Value 

func (a *Time32) Value(i int) arrow.Time32

Value returns the value at the specified index.

type Time32Builder 

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

func NewTime32Builder 

func NewTime32Builder(mem memory.Allocator, dtype *arrow.Time32Type) *Time32Builder

func (*Time32Builder) Append 

func (b *Time32Builder) Append(v arrow.Time32)

func (*Time32Builder) AppendNull 

func (b *Time32Builder) AppendNull()

func (*Time32Builder) AppendValues 

func (b *Time32Builder) AppendValues(v []arrow.Time32, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Time32Builder) Cap 

func (b *Time32Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Time32Builder) Len 

func (b *Time32Builder) Len() int

Len returns the number of elements in the array builder.

func (*Time32Builder) NewArray 

func (b *Time32Builder) NewArray() arrow.Array

NewArray creates a Time32 array from the memory buffers used by the builder and resets the Time32Builder so it can be used to build a new array.

func (*Time32Builder) NewTime32Array 

func (b *Time32Builder) NewTime32Array() (a *Time32)

NewTime32Array creates a Time32 array from the memory buffers used by the builder and resets the Time32Builder so it can be used to build a new array.

func (*Time32Builder) NullN 

func (b *Time32Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Time32Builder) Release 

func (b *Time32Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Time32Builder) Reserve 

func (b *Time32Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Time32Builder) Resize 

func (b *Time32Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Time32Builder) Retain 

func (b *Time32Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Time32Builder) UnmarshalJSON 

func (b *Time32Builder) UnmarshalJSON(data []byte) error

func (*Time32Builder) UnsafeAppend 

func (b *Time32Builder) UnsafeAppend(v arrow.Time32)

func (*Time32Builder) UnsafeAppendBoolToBitmap 

func (b *Time32Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Time32DictionaryBuilder 

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

func (*Time32DictionaryBuilder) Append 

func (b *Time32DictionaryBuilder) Append(v arrow.Time32) error

func (*Time32DictionaryBuilder) AppendArray 

func (b *Time32DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Time32DictionaryBuilder) AppendNull 

func (b *Time32DictionaryBuilder) AppendNull()

func (*Time32DictionaryBuilder) Cap 

func (b *Time32DictionaryBuilder) Cap() int

func (*Time32DictionaryBuilder) InsertDictValues 

func (b *Time32DictionaryBuilder) InsertDictValues(arr *Time32) (err error)

func (*Time32DictionaryBuilder) NewArray 

func (b *Time32DictionaryBuilder) NewArray() arrow.Array

func (*Time32DictionaryBuilder) NewDelta 

func (b *Time32DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Time32DictionaryBuilder) NewDictionaryArray 

func (b *Time32DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Time32DictionaryBuilder) Release 

func (b *Time32DictionaryBuilder) Release()

func (*Time32DictionaryBuilder) Reserve 

func (b *Time32DictionaryBuilder) Reserve(n int)

func (*Time32DictionaryBuilder) ResetFull 

func (b *Time32DictionaryBuilder) ResetFull()

func (*Time32DictionaryBuilder) Resize 

func (b *Time32DictionaryBuilder) Resize(n int)

func (*Time32DictionaryBuilder) UnmarshalJSON 

func (b *Time32DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Time64 

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

A type which represents an immutable sequence of arrow.Time64 values.

func NewTime64Data 

func NewTime64Data(data arrow.ArrayData) *Time64

NewTime64Data creates a new Time64.

func (*Time64) Data 

func (a *Time64) Data() arrow.ArrayData

func (*Time64) DataType 

func (a *Time64) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Time64) IsNull 

func (a *Time64) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Time64) IsValid 

func (a *Time64) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Time64) Len 

func (a *Time64) Len() int

Len returns the number of elements in the array.

func (*Time64) MarshalJSON 

func (a *Time64) MarshalJSON() ([]byte, error)

func (*Time64) NullBitmapBytes 

func (a *Time64) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Time64) NullN 

func (a *Time64) NullN() int

NullN returns the number of null values in the array.

func (*Time64) Offset 

func (a *Time64) Offset() int

func (*Time64) Release 

func (a *Time64) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Time64) Reset 

func (a *Time64) Reset(data *Data)

Reset resets the array for re-use.

func (*Time64) Retain 

func (a *Time64) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Time64) String 

func (a *Time64) String() string

String returns a string representation of the array.

func (*Time64) Time64Values 

func (a *Time64) Time64Values() []arrow.Time64

Values returns the values.

func (*Time64) Value 

func (a *Time64) Value(i int) arrow.Time64

Value returns the value at the specified index.

type Time64Builder 

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

func NewTime64Builder 

func NewTime64Builder(mem memory.Allocator, dtype *arrow.Time64Type) *Time64Builder

func (*Time64Builder) Append 

func (b *Time64Builder) Append(v arrow.Time64)

func (*Time64Builder) AppendNull 

func (b *Time64Builder) AppendNull()

func (*Time64Builder) AppendValues 

func (b *Time64Builder) AppendValues(v []arrow.Time64, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Time64Builder) Cap 

func (b *Time64Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Time64Builder) Len 

func (b *Time64Builder) Len() int

Len returns the number of elements in the array builder.

func (*Time64Builder) NewArray 

func (b *Time64Builder) NewArray() arrow.Array

NewArray creates a Time64 array from the memory buffers used by the builder and resets the Time64Builder so it can be used to build a new array.

func (*Time64Builder) NewTime64Array 

func (b *Time64Builder) NewTime64Array() (a *Time64)

NewTime64Array creates a Time64 array from the memory buffers used by the builder and resets the Time64Builder so it can be used to build a new array.

func (*Time64Builder) NullN 

func (b *Time64Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Time64Builder) Release 

func (b *Time64Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Time64Builder) Reserve 

func (b *Time64Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Time64Builder) Resize 

func (b *Time64Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Time64Builder) Retain 

func (b *Time64Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Time64Builder) UnmarshalJSON 

func (b *Time64Builder) UnmarshalJSON(data []byte) error

func (*Time64Builder) UnsafeAppend 

func (b *Time64Builder) UnsafeAppend(v arrow.Time64)

func (*Time64Builder) UnsafeAppendBoolToBitmap 

func (b *Time64Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Time64DictionaryBuilder 

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

func (*Time64DictionaryBuilder) Append 

func (b *Time64DictionaryBuilder) Append(v arrow.Time64) error

func (*Time64DictionaryBuilder) AppendArray 

func (b *Time64DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Time64DictionaryBuilder) AppendNull 

func (b *Time64DictionaryBuilder) AppendNull()

func (*Time64DictionaryBuilder) Cap 

func (b *Time64DictionaryBuilder) Cap() int

func (*Time64DictionaryBuilder) InsertDictValues 

func (b *Time64DictionaryBuilder) InsertDictValues(arr *Time64) (err error)

func (*Time64DictionaryBuilder) NewArray 

func (b *Time64DictionaryBuilder) NewArray() arrow.Array

func (*Time64DictionaryBuilder) NewDelta 

func (b *Time64DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Time64DictionaryBuilder) NewDictionaryArray 

func (b *Time64DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Time64DictionaryBuilder) Release 

func (b *Time64DictionaryBuilder) Release()

func (*Time64DictionaryBuilder) Reserve 

func (b *Time64DictionaryBuilder) Reserve(n int)

func (*Time64DictionaryBuilder) ResetFull 

func (b *Time64DictionaryBuilder) ResetFull()

func (*Time64DictionaryBuilder) Resize 

func (b *Time64DictionaryBuilder) Resize(n int)

func (*Time64DictionaryBuilder) UnmarshalJSON 

func (b *Time64DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Timestamp 

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

A type which represents an immutable sequence of arrow.Timestamp values.

func NewTimestampData 

func NewTimestampData(data arrow.ArrayData) *Timestamp

NewTimestampData creates a new Timestamp.

func (*Timestamp) Data 

func (a *Timestamp) Data() arrow.ArrayData

func (*Timestamp) DataType 

func (a *Timestamp) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Timestamp) IsNull 

func (a *Timestamp) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Timestamp) IsValid 

func (a *Timestamp) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Timestamp) Len 

func (a *Timestamp) Len() int

Len returns the number of elements in the array.

func (*Timestamp) MarshalJSON 

func (a *Timestamp) MarshalJSON() ([]byte, error)

func (*Timestamp) NullBitmapBytes 

func (a *Timestamp) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Timestamp) NullN 

func (a *Timestamp) NullN() int

NullN returns the number of null values in the array.

func (*Timestamp) Offset 

func (a *Timestamp) Offset() int

func (*Timestamp) Release 

func (a *Timestamp) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Timestamp) Reset 

func (a *Timestamp) Reset(data *Data)

Reset resets the array for re-use.

func (*Timestamp) Retain 

func (a *Timestamp) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Timestamp) String 

func (a *Timestamp) String() string

String returns a string representation of the array.

func (*Timestamp) TimestampValues 

func (a *Timestamp) TimestampValues() []arrow.Timestamp

Values returns the values.

func (*Timestamp) Value 

func (a *Timestamp) Value(i int) arrow.Timestamp

Value returns the value at the specified index.

type TimestampBuilder 

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

func NewTimestampBuilder 

func NewTimestampBuilder(mem memory.Allocator, dtype *arrow.TimestampType) *TimestampBuilder

func (*TimestampBuilder) Append 

func (b *TimestampBuilder) Append(v arrow.Timestamp)

func (*TimestampBuilder) AppendNull 

func (b *TimestampBuilder) AppendNull()

func (*TimestampBuilder) AppendValues 

func (b *TimestampBuilder) AppendValues(v []arrow.Timestamp, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*TimestampBuilder) Cap 

func (b *TimestampBuilder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*TimestampBuilder) Len 

func (b *TimestampBuilder) Len() int

Len returns the number of elements in the array builder.

func (*TimestampBuilder) NewArray 

func (b *TimestampBuilder) NewArray() arrow.Array

NewArray creates a Timestamp array from the memory buffers used by the builder and resets the TimestampBuilder so it can be used to build a new array.

func (*TimestampBuilder) NewTimestampArray 

func (b *TimestampBuilder) NewTimestampArray() (a *Timestamp)

NewTimestampArray creates a Timestamp array from the memory buffers used by the builder and resets the TimestampBuilder so it can be used to build a new array.

func (*TimestampBuilder) NullN 

func (b *TimestampBuilder) NullN() int

NullN returns the number of null values in the array builder.

func (*TimestampBuilder) Release 

func (b *TimestampBuilder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*TimestampBuilder) Reserve 

func (b *TimestampBuilder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*TimestampBuilder) Resize 

func (b *TimestampBuilder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*TimestampBuilder) Retain 

func (b *TimestampBuilder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*TimestampBuilder) UnmarshalJSON 

func (b *TimestampBuilder) UnmarshalJSON(data []byte) error

func (*TimestampBuilder) UnsafeAppend 

func (b *TimestampBuilder) UnsafeAppend(v arrow.Timestamp)

func (*TimestampBuilder) UnsafeAppendBoolToBitmap 

func (b *TimestampBuilder) UnsafeAppendBoolToBitmap(isValid bool)

type TimestampDictionaryBuilder 

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

func (*TimestampDictionaryBuilder) Append 

func (b *TimestampDictionaryBuilder) Append(v arrow.Timestamp) error

func (*TimestampDictionaryBuilder) AppendArray 

func (b *TimestampDictionaryBuilder) AppendArray(arr arrow.Array) error

func (*TimestampDictionaryBuilder) AppendNull 

func (b *TimestampDictionaryBuilder) AppendNull()

func (*TimestampDictionaryBuilder) Cap 

func (b *TimestampDictionaryBuilder) Cap() int

func (*TimestampDictionaryBuilder) InsertDictValues 

func (b *TimestampDictionaryBuilder) InsertDictValues(arr *Timestamp) (err error)

func (*TimestampDictionaryBuilder) NewArray 

func (b *TimestampDictionaryBuilder) NewArray() arrow.Array

func (*TimestampDictionaryBuilder) NewDelta 

func (b *TimestampDictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*TimestampDictionaryBuilder) NewDictionaryArray 

func (b *TimestampDictionaryBuilder) NewDictionaryArray() *Dictionary

func (*TimestampDictionaryBuilder) Release 

func (b *TimestampDictionaryBuilder) Release()

func (*TimestampDictionaryBuilder) Reserve 

func (b *TimestampDictionaryBuilder) Reserve(n int)

func (*TimestampDictionaryBuilder) ResetFull 

func (b *TimestampDictionaryBuilder) ResetFull()

func (*TimestampDictionaryBuilder) Resize 

func (b *TimestampDictionaryBuilder) Resize(n int)

func (*TimestampDictionaryBuilder) UnmarshalJSON 

func (b *TimestampDictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Uint16 

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

A type which represents an immutable sequence of uint16 values.

func NewUint16Data 

func NewUint16Data(data arrow.ArrayData) *Uint16

NewUint16Data creates a new Uint16.

func (*Uint16) Data 

func (a *Uint16) Data() arrow.ArrayData

func (*Uint16) DataType 

func (a *Uint16) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Uint16) IsNull 

func (a *Uint16) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Uint16) IsValid 

func (a *Uint16) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Uint16) Len 

func (a *Uint16) Len() int

Len returns the number of elements in the array.

func (*Uint16) MarshalJSON 

func (a *Uint16) MarshalJSON() ([]byte, error)

func (*Uint16) NullBitmapBytes 

func (a *Uint16) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Uint16) NullN 

func (a *Uint16) NullN() int

NullN returns the number of null values in the array.

func (*Uint16) Offset 

func (a *Uint16) Offset() int

func (*Uint16) Release 

func (a *Uint16) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Uint16) Reset 

func (a *Uint16) Reset(data *Data)

Reset resets the array for re-use.

func (*Uint16) Retain 

func (a *Uint16) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Uint16) String 

func (a *Uint16) String() string

String returns a string representation of the array.

func (*Uint16) Uint16Values 

func (a *Uint16) Uint16Values() []uint16

Values returns the values.

func (*Uint16) Value 

func (a *Uint16) Value(i int) uint16

Value returns the value at the specified index.

type Uint16Builder 

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

func NewUint16Builder 

func NewUint16Builder(mem memory.Allocator) *Uint16Builder

func (*Uint16Builder) Append 

func (b *Uint16Builder) Append(v uint16)

func (*Uint16Builder) AppendNull 

func (b *Uint16Builder) AppendNull()

func (*Uint16Builder) AppendValues 

func (b *Uint16Builder) AppendValues(v []uint16, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Uint16Builder) Cap 

func (b *Uint16Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Uint16Builder) Len 

func (b *Uint16Builder) Len() int

Len returns the number of elements in the array builder.

func (*Uint16Builder) NewArray 

func (b *Uint16Builder) NewArray() arrow.Array

NewArray creates a Uint16 array from the memory buffers used by the builder and resets the Uint16Builder so it can be used to build a new array.

func (*Uint16Builder) NewUint16Array 

func (b *Uint16Builder) NewUint16Array() (a *Uint16)

NewUint16Array creates a Uint16 array from the memory buffers used by the builder and resets the Uint16Builder so it can be used to build a new array.

func (*Uint16Builder) NullN 

func (b *Uint16Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Uint16Builder) Release 

func (b *Uint16Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Uint16Builder) Reserve 

func (b *Uint16Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Uint16Builder) Resize 

func (b *Uint16Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Uint16Builder) Retain 

func (b *Uint16Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Uint16Builder) UnmarshalJSON 

func (b *Uint16Builder) UnmarshalJSON(data []byte) error

func (*Uint16Builder) UnsafeAppend 

func (b *Uint16Builder) UnsafeAppend(v uint16)

func (*Uint16Builder) UnsafeAppendBoolToBitmap 

func (b *Uint16Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Uint16DictionaryBuilder 

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

func (*Uint16DictionaryBuilder) Append 

func (b *Uint16DictionaryBuilder) Append(v uint16) error

func (*Uint16DictionaryBuilder) AppendArray 

func (b *Uint16DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Uint16DictionaryBuilder) AppendNull 

func (b *Uint16DictionaryBuilder) AppendNull()

func (*Uint16DictionaryBuilder) Cap 

func (b *Uint16DictionaryBuilder) Cap() int

func (*Uint16DictionaryBuilder) InsertDictValues 

func (b *Uint16DictionaryBuilder) InsertDictValues(arr *Uint16) (err error)

func (*Uint16DictionaryBuilder) NewArray 

func (b *Uint16DictionaryBuilder) NewArray() arrow.Array

func (*Uint16DictionaryBuilder) NewDelta 

func (b *Uint16DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Uint16DictionaryBuilder) NewDictionaryArray 

func (b *Uint16DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Uint16DictionaryBuilder) Release 

func (b *Uint16DictionaryBuilder) Release()

func (*Uint16DictionaryBuilder) Reserve 

func (b *Uint16DictionaryBuilder) Reserve(n int)

func (*Uint16DictionaryBuilder) ResetFull 

func (b *Uint16DictionaryBuilder) ResetFull()

func (*Uint16DictionaryBuilder) Resize 

func (b *Uint16DictionaryBuilder) Resize(n int)

func (*Uint16DictionaryBuilder) UnmarshalJSON 

func (b *Uint16DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Uint32 

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

A type which represents an immutable sequence of uint32 values.

func NewUint32Data 

func NewUint32Data(data arrow.ArrayData) *Uint32

NewUint32Data creates a new Uint32.

func (*Uint32) Data 

func (a *Uint32) Data() arrow.ArrayData

func (*Uint32) DataType 

func (a *Uint32) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Uint32) IsNull 

func (a *Uint32) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Uint32) IsValid 

func (a *Uint32) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Uint32) Len 

func (a *Uint32) Len() int

Len returns the number of elements in the array.

func (*Uint32) MarshalJSON 

func (a *Uint32) MarshalJSON() ([]byte, error)

func (*Uint32) NullBitmapBytes 

func (a *Uint32) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Uint32) NullN 

func (a *Uint32) NullN() int

NullN returns the number of null values in the array.

func (*Uint32) Offset 

func (a *Uint32) Offset() int

func (*Uint32) Release 

func (a *Uint32) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Uint32) Reset 

func (a *Uint32) Reset(data *Data)

Reset resets the array for re-use.

func (*Uint32) Retain 

func (a *Uint32) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Uint32) String 

func (a *Uint32) String() string

String returns a string representation of the array.

func (*Uint32) Uint32Values 

func (a *Uint32) Uint32Values() []uint32

Values returns the values.

func (*Uint32) Value 

func (a *Uint32) Value(i int) uint32

Value returns the value at the specified index.

type Uint32Builder 

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

func NewUint32Builder 

func NewUint32Builder(mem memory.Allocator) *Uint32Builder

func (*Uint32Builder) Append 

func (b *Uint32Builder) Append(v uint32)

func (*Uint32Builder) AppendNull 

func (b *Uint32Builder) AppendNull()

func (*Uint32Builder) AppendValues 

func (b *Uint32Builder) AppendValues(v []uint32, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Uint32Builder) Cap 

func (b *Uint32Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Uint32Builder) Len 

func (b *Uint32Builder) Len() int

Len returns the number of elements in the array builder.

func (*Uint32Builder) NewArray 

func (b *Uint32Builder) NewArray() arrow.Array

NewArray creates a Uint32 array from the memory buffers used by the builder and resets the Uint32Builder so it can be used to build a new array.

func (*Uint32Builder) NewUint32Array 

func (b *Uint32Builder) NewUint32Array() (a *Uint32)

NewUint32Array creates a Uint32 array from the memory buffers used by the builder and resets the Uint32Builder so it can be used to build a new array.

func (*Uint32Builder) NullN 

func (b *Uint32Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Uint32Builder) Release 

func (b *Uint32Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Uint32Builder) Reserve 

func (b *Uint32Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Uint32Builder) Resize 

func (b *Uint32Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Uint32Builder) Retain 

func (b *Uint32Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Uint32Builder) UnmarshalJSON 

func (b *Uint32Builder) UnmarshalJSON(data []byte) error

func (*Uint32Builder) UnsafeAppend 

func (b *Uint32Builder) UnsafeAppend(v uint32)

func (*Uint32Builder) UnsafeAppendBoolToBitmap 

func (b *Uint32Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Uint32DictionaryBuilder 

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

func (*Uint32DictionaryBuilder) Append 

func (b *Uint32DictionaryBuilder) Append(v uint32) error

func (*Uint32DictionaryBuilder) AppendArray 

func (b *Uint32DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Uint32DictionaryBuilder) AppendNull 

func (b *Uint32DictionaryBuilder) AppendNull()

func (*Uint32DictionaryBuilder) Cap 

func (b *Uint32DictionaryBuilder) Cap() int

func (*Uint32DictionaryBuilder) InsertDictValues 

func (b *Uint32DictionaryBuilder) InsertDictValues(arr *Uint32) (err error)

func (*Uint32DictionaryBuilder) NewArray 

func (b *Uint32DictionaryBuilder) NewArray() arrow.Array

func (*Uint32DictionaryBuilder) NewDelta 

func (b *Uint32DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Uint32DictionaryBuilder) NewDictionaryArray 

func (b *Uint32DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Uint32DictionaryBuilder) Release 

func (b *Uint32DictionaryBuilder) Release()

func (*Uint32DictionaryBuilder) Reserve 

func (b *Uint32DictionaryBuilder) Reserve(n int)

func (*Uint32DictionaryBuilder) ResetFull 

func (b *Uint32DictionaryBuilder) ResetFull()

func (*Uint32DictionaryBuilder) Resize 

func (b *Uint32DictionaryBuilder) Resize(n int)

func (*Uint32DictionaryBuilder) UnmarshalJSON 

func (b *Uint32DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Uint64 

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

A type which represents an immutable sequence of uint64 values.

func NewUint64Data 

func NewUint64Data(data arrow.ArrayData) *Uint64

NewUint64Data creates a new Uint64.

func (*Uint64) Data 

func (a *Uint64) Data() arrow.ArrayData

func (*Uint64) DataType 

func (a *Uint64) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Uint64) IsNull 

func (a *Uint64) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Uint64) IsValid 

func (a *Uint64) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Uint64) Len 

func (a *Uint64) Len() int

Len returns the number of elements in the array.

func (*Uint64) MarshalJSON 

func (a *Uint64) MarshalJSON() ([]byte, error)

func (*Uint64) NullBitmapBytes 

func (a *Uint64) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Uint64) NullN 

func (a *Uint64) NullN() int

NullN returns the number of null values in the array.

func (*Uint64) Offset 

func (a *Uint64) Offset() int

func (*Uint64) Release 

func (a *Uint64) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Uint64) Reset 

func (a *Uint64) Reset(data *Data)

Reset resets the array for re-use.

func (*Uint64) Retain 

func (a *Uint64) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Uint64) String 

func (a *Uint64) String() string

String returns a string representation of the array.

func (*Uint64) Uint64Values 

func (a *Uint64) Uint64Values() []uint64

Values returns the values.

func (*Uint64) Value 

func (a *Uint64) Value(i int) uint64

Value returns the value at the specified index.

type Uint64Builder 

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

func NewUint64Builder 

func NewUint64Builder(mem memory.Allocator) *Uint64Builder

func (*Uint64Builder) Append 

func (b *Uint64Builder) Append(v uint64)

func (*Uint64Builder) AppendNull 

func (b *Uint64Builder) AppendNull()

func (*Uint64Builder) AppendValues 

func (b *Uint64Builder) AppendValues(v []uint64, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Uint64Builder) Cap 

func (b *Uint64Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Uint64Builder) Len 

func (b *Uint64Builder) Len() int

Len returns the number of elements in the array builder.

func (*Uint64Builder) NewArray 

func (b *Uint64Builder) NewArray() arrow.Array

NewArray creates a Uint64 array from the memory buffers used by the builder and resets the Uint64Builder so it can be used to build a new array.

func (*Uint64Builder) NewUint64Array 

func (b *Uint64Builder) NewUint64Array() (a *Uint64)

NewUint64Array creates a Uint64 array from the memory buffers used by the builder and resets the Uint64Builder so it can be used to build a new array.

func (*Uint64Builder) NullN 

func (b *Uint64Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Uint64Builder) Release 

func (b *Uint64Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Uint64Builder) Reserve 

func (b *Uint64Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Uint64Builder) Resize 

func (b *Uint64Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Uint64Builder) Retain 

func (b *Uint64Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Uint64Builder) UnmarshalJSON 

func (b *Uint64Builder) UnmarshalJSON(data []byte) error

func (*Uint64Builder) UnsafeAppend 

func (b *Uint64Builder) UnsafeAppend(v uint64)

func (*Uint64Builder) UnsafeAppendBoolToBitmap 

func (b *Uint64Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Uint64DictionaryBuilder 

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

func (*Uint64DictionaryBuilder) Append 

func (b *Uint64DictionaryBuilder) Append(v uint64) error

func (*Uint64DictionaryBuilder) AppendArray 

func (b *Uint64DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Uint64DictionaryBuilder) AppendNull 

func (b *Uint64DictionaryBuilder) AppendNull()

func (*Uint64DictionaryBuilder) Cap 

func (b *Uint64DictionaryBuilder) Cap() int

func (*Uint64DictionaryBuilder) InsertDictValues 

func (b *Uint64DictionaryBuilder) InsertDictValues(arr *Uint64) (err error)

func (*Uint64DictionaryBuilder) NewArray 

func (b *Uint64DictionaryBuilder) NewArray() arrow.Array

func (*Uint64DictionaryBuilder) NewDelta 

func (b *Uint64DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Uint64DictionaryBuilder) NewDictionaryArray 

func (b *Uint64DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Uint64DictionaryBuilder) Release 

func (b *Uint64DictionaryBuilder) Release()

func (*Uint64DictionaryBuilder) Reserve 

func (b *Uint64DictionaryBuilder) Reserve(n int)

func (*Uint64DictionaryBuilder) ResetFull 

func (b *Uint64DictionaryBuilder) ResetFull()

func (*Uint64DictionaryBuilder) Resize 

func (b *Uint64DictionaryBuilder) Resize(n int)

func (*Uint64DictionaryBuilder) UnmarshalJSON 

func (b *Uint64DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

type Uint8 

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

A type which represents an immutable sequence of uint8 values.

func NewUint8Data 

func NewUint8Data(data arrow.ArrayData) *Uint8

NewUint8Data creates a new Uint8.

func (*Uint8) Data 

func (a *Uint8) Data() arrow.ArrayData

func (*Uint8) DataType 

func (a *Uint8) DataType() arrow.DataType

DataType returns the type metadata for this instance.

func (*Uint8) IsNull 

func (a *Uint8) IsNull(i int) bool

IsNull returns true if value at index is null. NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Uint8) IsValid 

func (a *Uint8) IsValid(i int) bool

IsValid returns true if value at index is not null. NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.

func (*Uint8) Len 

func (a *Uint8) Len() int

Len returns the number of elements in the array.

func (*Uint8) MarshalJSON 

func (a *Uint8) MarshalJSON() ([]byte, error)

func (*Uint8) NullBitmapBytes 

func (a *Uint8) NullBitmapBytes() []byte

NullBitmapBytes returns a byte slice of the validity bitmap.

func (*Uint8) NullN 

func (a *Uint8) NullN() int

NullN returns the number of null values in the array.

func (*Uint8) Offset 

func (a *Uint8) Offset() int

func (*Uint8) Release 

func (a *Uint8) Release()

Release decreases the reference count by 1. Release may be called simultaneously from multiple goroutines. When the reference count goes to zero, the memory is freed.

func (*Uint8) Reset 

func (a *Uint8) Reset(data *Data)

Reset resets the array for re-use.

func (*Uint8) Retain 

func (a *Uint8) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Uint8) String 

func (a *Uint8) String() string

String returns a string representation of the array.

func (*Uint8) Uint8Values 

func (a *Uint8) Uint8Values() []uint8

Values returns the values.

func (*Uint8) Value 

func (a *Uint8) Value(i int) uint8

Value returns the value at the specified index.

type Uint8Builder 

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

func NewUint8Builder 

func NewUint8Builder(mem memory.Allocator) *Uint8Builder

func (*Uint8Builder) Append 

func (b *Uint8Builder) Append(v uint8)

func (*Uint8Builder) AppendNull 

func (b *Uint8Builder) AppendNull()

func (*Uint8Builder) AppendValues 

func (b *Uint8Builder) AppendValues(v []uint8, valid []bool)

AppendValues will append the values in the v slice. The valid slice determines which values in v are valid (not null). The valid slice must either be empty or be equal in length to v. If empty, all values in v are appended and considered valid.

func (*Uint8Builder) Cap 

func (b *Uint8Builder) Cap() int

Cap returns the total number of elements that can be stored without allocating additional memory.

func (*Uint8Builder) Len 

func (b *Uint8Builder) Len() int

Len returns the number of elements in the array builder.

func (*Uint8Builder) NewArray 

func (b *Uint8Builder) NewArray() arrow.Array

NewArray creates a Uint8 array from the memory buffers used by the builder and resets the Uint8Builder so it can be used to build a new array.

func (*Uint8Builder) NewUint8Array 

func (b *Uint8Builder) NewUint8Array() (a *Uint8)

NewUint8Array creates a Uint8 array from the memory buffers used by the builder and resets the Uint8Builder so it can be used to build a new array.

func (*Uint8Builder) NullN 

func (b *Uint8Builder) NullN() int

NullN returns the number of null values in the array builder.

func (*Uint8Builder) Release 

func (b *Uint8Builder) Release()

Release decreases the reference count by 1. When the reference count goes to zero, the memory is freed.

func (*Uint8Builder) Reserve 

func (b *Uint8Builder) Reserve(n int)

Reserve ensures there is enough space for appending n elements by checking the capacity and calling Resize if necessary.

func (*Uint8Builder) Resize 

func (b *Uint8Builder) Resize(n int)

Resize adjusts the space allocated by b to n elements. If n is greater than b.Cap(), additional memory will be allocated. If n is smaller, the allocated memory may reduced.

func (*Uint8Builder) Retain 

func (b *Uint8Builder) Retain()

Retain increases the reference count by 1. Retain may be called simultaneously from multiple goroutines.

func (*Uint8Builder) UnmarshalJSON 

func (b *Uint8Builder) UnmarshalJSON(data []byte) error

func (*Uint8Builder) UnsafeAppend 

func (b *Uint8Builder) UnsafeAppend(v uint8)

func (*Uint8Builder) UnsafeAppendBoolToBitmap 

func (b *Uint8Builder) UnsafeAppendBoolToBitmap(isValid bool)

type Uint8DictionaryBuilder 

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

func (*Uint8DictionaryBuilder) Append 

func (b *Uint8DictionaryBuilder) Append(v uint8) error

func (*Uint8DictionaryBuilder) AppendArray 

func (b *Uint8DictionaryBuilder) AppendArray(arr arrow.Array) error

func (*Uint8DictionaryBuilder) AppendNull 

func (b *Uint8DictionaryBuilder) AppendNull()

func (*Uint8DictionaryBuilder) Cap 

func (b *Uint8DictionaryBuilder) Cap() int

func (*Uint8DictionaryBuilder) InsertDictValues 

func (b *Uint8DictionaryBuilder) InsertDictValues(arr *Uint8) (err error)

func (*Uint8DictionaryBuilder) NewArray 

func (b *Uint8DictionaryBuilder) NewArray() arrow.Array

func (*Uint8DictionaryBuilder) NewDelta 

func (b *Uint8DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)

NewDelta returns the dictionary indices and a delta dictionary since the last time NewArray or NewDictionaryArray were called, and resets the state of the builder (except for the dictionary / memotable)

func (*Uint8DictionaryBuilder) NewDictionaryArray 

func (b *Uint8DictionaryBuilder) NewDictionaryArray() *Dictionary

func (*Uint8DictionaryBuilder) Release 

func (b *Uint8DictionaryBuilder) Release()

func (*Uint8DictionaryBuilder) Reserve 

func (b *Uint8DictionaryBuilder) Reserve(n int)

func (*Uint8DictionaryBuilder) ResetFull 

func (b *Uint8DictionaryBuilder) ResetFull()

func (*Uint8DictionaryBuilder) Resize 

func (b *Uint8DictionaryBuilder) Resize(n int)

func (*Uint8DictionaryBuilder) UnmarshalJSON 

func (b *Uint8DictionaryBuilder) UnmarshalJSON(data []byte) error

UnmarshalJSON is not yet implemented for dictionary builders and will always error.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.