package array
Import Path
github.com/apache/arrow-go/v18/arrow/array (on go.dev)
Dependency Relation
imports 26 packages, and imported by 17 packages
Involved Source Files
array.go
binary.go
binarybuilder.go
boolean.go
booleanbuilder.go
bufferbuilder.go
bufferbuilder_byte.go
bufferbuilder_numeric.gen.go
builder.go
compare.go
concat.go
data.go
decimal.go
dictionary.go
diff.go
Package array provides implementations of various Arrow array types.
encoded.go
extension.go
extension_builder.go
fixed_size_list.go
fixedsize_binary.go
fixedsize_binarybuilder.go
float16.go
float16_builder.go
interval.go
json_reader.go
list.go
map.go
null.go
numeric_generic.go
numericbuilder.gen.go
record.go
string.go
struct.go
table.go
timestamp.go
union.go
util.go
Code Examples
package main
import (
"fmt"
"github.com/apache/arrow-go/v18/arrow"
"github.com/apache/arrow-go/v18/arrow/array"
"github.com/apache/arrow-go/v18/arrow/memory"
)
func main() {
pool := memory.NewGoAllocator()
// 1. Basic type conversion (Int32 to Int64)
fmt.Println("Example 1: Converting Int32 to Int64")
int32Builder := array.NewInt32Builder(pool)
defer int32Builder.Release()
int32Builder.AppendValues([]int32{1, 2, 3, 4, 5}, nil)
int32Array := int32Builder.NewInt32Array()
defer int32Array.Release()
// Convert to Int64
int64Builder := array.NewInt64Builder(pool)
defer int64Builder.Release()
for i := 0; i < int32Array.Len(); i++ {
int64Builder.Append(int64(int32Array.Value(i)))
}
int64Array := int64Builder.NewInt64Array()
defer int64Array.Release()
fmt.Printf("Original Int32 values: %v\n", int32Array.Int32Values())
fmt.Printf("Converted Int64 values: %v\n", int64Array.Int64Values())
// 2. Handling nullable fields
fmt.Println("\nExample 2: Working with nullable fields")
float64Builder := array.NewFloat64Builder(pool)
defer float64Builder.Release()
values := []float64{1.1, 2.2, 3.3, 4.4, 5.5}
valid := []bool{true, true, false, true, false}
float64Builder.AppendValues(values, valid)
float64Array := float64Builder.NewFloat64Array()
defer float64Array.Release()
stringBuilder := array.NewStringBuilder(pool)
defer stringBuilder.Release()
for i := 0; i < float64Array.Len(); i++ {
if float64Array.IsNull(i) {
stringBuilder.AppendNull()
} else {
stringBuilder.Append(fmt.Sprintf("%.2f", float64Array.Value(i)))
}
}
stringArray := stringBuilder.NewStringArray()
defer stringArray.Release()
fmt.Println("Original Float64 values (with nulls):")
for i := 0; i < float64Array.Len(); i++ {
if float64Array.IsNull(i) {
fmt.Printf(" [%d]: null\n", i)
} else {
fmt.Printf(" [%d]: %.2f\n", i, float64Array.Value(i))
}
}
fmt.Println("\nConverted String values (with nulls):")
for i := 0; i < stringArray.Len(); i++ {
if stringArray.IsNull(i) {
fmt.Printf(" [%d]: null\n", i)
} else {
fmt.Printf(" [%d]: %s\n", i, stringArray.Value(i))
}
}
// 3. Working with nested types (List)
fmt.Println("\nExample 3: Working with nested types (List)")
listBuilder := array.NewListBuilder(pool, arrow.PrimitiveTypes.Int32)
defer listBuilder.Release()
valueBuilder := listBuilder.ValueBuilder().(*array.Int32Builder)
listBuilder.Append(true)
valueBuilder.AppendValues([]int32{1, 2}, nil)
listBuilder.Append(true)
valueBuilder.AppendValues([]int32{3, 4, 5}, nil)
listBuilder.Append(true)
valueBuilder.AppendValues([]int32{6}, nil)
listArray := listBuilder.NewListArray()
defer listArray.Release()
// Convert list to string representation
fmt.Println("List of lists:")
for i := 0; i < listArray.Len(); i++ {
values := listArray.ListValues().(*array.Int32).Int32Values()
offset := listArray.Offsets()[i]
length := listArray.Offsets()[i+1] - offset
fmt.Printf(" List %d: %v\n", i, values[offset:offset+length])
}
}
Package-Level Type Names (total 142)
A type which represents an immutable sequence of variable-length binary strings.
(*Binary) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Binary) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Binary) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Binary) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Binary) String() string
Value returns the slice at index i. This value should not be mutated.
(*Binary) ValueBytes() []byte
(*Binary) ValueLen(i int) int
(*Binary) ValueOffset(i int) int
(*Binary) ValueOffset64(i int) int64
(*Binary) ValueOffsets() []int32
ValueStr returns a copy of the base64-encoded string value or NullValueStr
ValueString returns the string at index i without performing additional allocations.
The string is only valid for the lifetime of the Binary array.
*Binary : BinaryLike
*Binary : github.com/apache/arrow-go/v18/arrow.Array[T]
*Binary : github.com/apache/arrow-go/v18/arrow.TypedArray[[]byte]
*Binary : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Binary : github.com/goccy/go-json.Marshaler
*Binary : encoding/json.Marshaler
*Binary : expvar.Var
*Binary : fmt.Stringer
func NewBinaryData(data arrow.ArrayData) *Binary
func (*BinaryBuilder).NewBinaryArray() (a *Binary)
func (*BinaryDictionaryBuilder).InsertDictValues(arr *Binary) (err error)
func github.com/polarsignals/frostdb/query/physicalplan.BinaryArrayScalarRegexMatch(left *Binary, right *regexp.Regexp) (*physicalplan.Bitmap, error)
func github.com/polarsignals/frostdb/query/physicalplan.BinaryArrayScalarRegexNotMatch(left *Binary, right *regexp.Regexp) (*physicalplan.Bitmap, error)
func github.com/polarsignals/frostdb/query/physicalplan.BinaryDictionaryArrayScalarRegexMatch(dict *Dictionary, left *Binary, right *regexp.Regexp) (*physicalplan.Bitmap, error)
func github.com/polarsignals/frostdb/query/physicalplan.BinaryDictionaryArrayScalarRegexNotMatch(dict *Dictionary, left *Binary, right *regexp.Regexp) (*physicalplan.Bitmap, error)
A BinaryBuilder is used to build a Binary array using the Append methods.
(*BinaryBuilder) Append(v []byte)
(*BinaryBuilder) AppendEmptyValue()
(*BinaryBuilder) AppendEmptyValues(n int)
(*BinaryBuilder) AppendNull()
(*BinaryBuilder) AppendNulls(n int)
(*BinaryBuilder) AppendString(v string)
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.
(*BinaryBuilder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
DataCap returns the total number of bytes that can be stored
without allocating additional memory.
DataLen returns the number of bytes in the data array.
(*BinaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
Builds the appropriate Binary or LargeBinary array based on the datatype
it was initialized with.
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.
(*BinaryBuilder) NewLargeBinaryArray() (a *LargeBinary)
NullN returns the number of null values in the array builder.
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.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
ReserveData ensures there is enough space for appending n bytes
by checking the capacity and resizing the data buffer if necessary.
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.
(*BinaryBuilder) ResizeData(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*BinaryBuilder) SetNull(i int)
(*BinaryBuilder) Type() arrow.DataType
(*BinaryBuilder) Unmarshal(dec *json.Decoder) error
(*BinaryBuilder) UnmarshalJSON(data []byte) error
(*BinaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*BinaryBuilder) UnsafeAppend(v []byte)
(*BinaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
(*BinaryBuilder) Value(i int) []byte
*BinaryBuilder : BinaryLikeBuilder
*BinaryBuilder : Builder
*BinaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*BinaryBuilder : github.com/apache/arrow-go/v18/internal/hashing.BinaryBuilderIFace
*BinaryBuilder : github.com/goccy/go-json.Unmarshaler
*BinaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*BinaryBuilder : encoding/json.Unmarshaler
func NewBinaryBuilder(mem memory.Allocator, dtype arrow.BinaryDataType) *BinaryBuilder
(*BinaryDictionaryBuilder) Append(v []byte) error
(*BinaryDictionaryBuilder) AppendArray(arr arrow.Array) error
(*BinaryDictionaryBuilder) AppendEmptyValue()
(*BinaryDictionaryBuilder) AppendEmptyValues(n int)
(*BinaryDictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*BinaryDictionaryBuilder) AppendNull()
(*BinaryDictionaryBuilder) AppendNulls(n int)
(*BinaryDictionaryBuilder) AppendString(v string) error
(*BinaryDictionaryBuilder) AppendValueFromString(s string) error
(*BinaryDictionaryBuilder) Cap() int
(*BinaryDictionaryBuilder) DictionarySize() int
(*BinaryDictionaryBuilder) GetValueIndex(i int) int
(*BinaryDictionaryBuilder) IndexBuilder() IndexBuilder
(*BinaryDictionaryBuilder) InsertDictValues(arr *Binary) (err error)
(*BinaryDictionaryBuilder) InsertStringDictValues(arr *String) (err error)
(*BinaryDictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*BinaryDictionaryBuilder) NewArray() arrow.Array
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)
(*BinaryDictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*BinaryDictionaryBuilder) Release()
(*BinaryDictionaryBuilder) Reserve(n int)
(*BinaryDictionaryBuilder) ResetFull()
(*BinaryDictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*BinaryDictionaryBuilder) SetNull(i int)
(*BinaryDictionaryBuilder) Type() arrow.DataType
(*BinaryDictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*BinaryDictionaryBuilder) UnmarshalJSON(data []byte) error
(*BinaryDictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*BinaryDictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
(*BinaryDictionaryBuilder) Value(i int) []byte
(*BinaryDictionaryBuilder) ValueStr(i int) string
*BinaryDictionaryBuilder : Builder
*BinaryDictionaryBuilder : DictionaryBuilder
*BinaryDictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*BinaryDictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*BinaryDictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*BinaryDictionaryBuilder : encoding/json.Unmarshaler
( BinaryLike) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
Get single value to be marshalled with `json.Marshal`
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
( BinaryLike) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( BinaryLike) String() string
( BinaryLike) ValueBytes() []byte
( BinaryLike) ValueLen(int) int
( BinaryLike) ValueOffset64(int) int64
ValueStr returns the value at index as a string.
*Binary
*LargeBinary
*LargeString
*String
BinaryLike : github.com/apache/arrow-go/v18/arrow.Array[T]
BinaryLike : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
BinaryLike : github.com/goccy/go-json.Marshaler
BinaryLike : encoding/json.Marshaler
BinaryLike : expvar.Var
BinaryLike : fmt.Stringer
( BinaryLikeBuilder) Append([]byte)
AppendEmptyValue adds a new zero value of the appropriate type
AppendEmptyValues adds new n zero values of the appropriate type
AppendNull adds a new null value to the array being built.
AppendNulls adds new n null values to the array being built.
AppendValueFromString adds a new value from a string. Inverse of array.ValueStr(i int) string
( BinaryLikeBuilder) AppendValues([][]byte, []bool)
Cap returns the total number of elements that can be stored
without allocating additional memory.
IsNull returns if a previously appended value at a given index is null or not.
Len returns the number of elements in the array builder.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
( BinaryLikeBuilder) ReserveData(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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
SetNull sets the value at index i to null.
Type returns the datatype that this is building
( BinaryLikeBuilder) Unmarshal(*json.Decoder) error
( BinaryLikeBuilder) UnmarshalJSON([]byte) error
( BinaryLikeBuilder) UnmarshalOne(*json.Decoder) error
( BinaryLikeBuilder) UnsafeAppend([]byte)
( BinaryLikeBuilder) UnsafeAppendBoolToBitmap(bool)
*BinaryBuilder
*BinaryViewBuilder
BinaryLikeBuilder : Builder
BinaryLikeBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
BinaryLikeBuilder : github.com/goccy/go-json.Unmarshaler
BinaryLikeBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
BinaryLikeBuilder : encoding/json.Unmarshaler
(*BinaryView) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*BinaryView) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*BinaryView) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*BinaryView) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*BinaryView) String() string
(*BinaryView) Value(i int) []byte
(*BinaryView) ValueHeader(i int) *arrow.ViewHeader
(*BinaryView) ValueLen(i int) int
ValueStr is paired with AppendValueFromString in that it returns
the value at index i as a string: Semantically this means that for
a null value it will return the string "(null)", otherwise it will
return the value as a base64 encoded string suitable for CSV/JSON.
This is always going to be less performant than just using ValueString
and exists to fulfill the Array interface to provide a method which
can produce a human readable string for a given index.
ValueString returns the value at index i as a string instead of
a byte slice, without copying the underlying data.
*BinaryView : ViewLike
*BinaryView : github.com/apache/arrow-go/v18/arrow.Array[T]
*BinaryView : github.com/apache/arrow-go/v18/arrow.TypedArray[[]byte]
*BinaryView : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*BinaryView : github.com/goccy/go-json.Marshaler
*BinaryView : encoding/json.Marshaler
*BinaryView : expvar.Var
*BinaryView : fmt.Stringer
func NewBinaryViewData(data arrow.ArrayData) *BinaryView
func (*BinaryViewBuilder).NewBinaryViewArray() (a *BinaryView)
(*BinaryViewBuilder) Append(v []byte)
(*BinaryViewBuilder) AppendEmptyValue()
(*BinaryViewBuilder) AppendEmptyValues(n int)
(*BinaryViewBuilder) AppendNull()
(*BinaryViewBuilder) AppendNulls(n int)
AppendString is identical to Append, only accepting a string instead
of a byte slice, avoiding the extra copy that would occur if you simply
did []byte(v).
This is different than AppendValueFromString which exists for the
Builder interface, in that this expects raw binary data which is
appended unmodified. AppendValueFromString expects base64 encoded binary
data instead.
(*BinaryViewBuilder) AppendStringValues(v []string, valid []bool)
AppendValueFromString is paired with ValueStr for fulfilling the
base Builder interface. This is intended to read in a human-readable
string such as from CSV or JSON and append it to the array.
For Binary values are expected to be base64 encoded (and will be
decoded as such before being appended).
(*BinaryViewBuilder) AppendValues(v [][]byte, valid []bool)
Cap returns the total number of elements that can be stored without allocating additional memory.
(*BinaryViewBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*BinaryViewBuilder) NewArray() arrow.Array
(*BinaryViewBuilder) NewBinaryViewArray() (a *BinaryView)
NullN returns the number of null values in the array builder.
(*BinaryViewBuilder) Release()
(*BinaryViewBuilder) Reserve(n int)
(*BinaryViewBuilder) ReserveData(length int)
(*BinaryViewBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*BinaryViewBuilder) SetBlockSize(sz uint)
(*BinaryViewBuilder) SetNull(i int)
(*BinaryViewBuilder) Type() arrow.DataType
(*BinaryViewBuilder) Unmarshal(dec *json.Decoder) error
(*BinaryViewBuilder) UnmarshalJSON(data []byte) error
(*BinaryViewBuilder) UnmarshalOne(dec *json.Decoder) error
(*BinaryViewBuilder) UnsafeAppend(v []byte)
(*BinaryViewBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*BinaryViewBuilder : BinaryLikeBuilder
*BinaryViewBuilder : Builder
*BinaryViewBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*BinaryViewBuilder : github.com/goccy/go-json.Unmarshaler
*BinaryViewBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*BinaryViewBuilder : encoding/json.Unmarshaler
func NewBinaryViewBuilder(mem memory.Allocator) *BinaryViewBuilder
A type which represents an immutable sequence of boolean values.
(*Boolean) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Boolean) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Boolean) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Boolean) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Boolean) String() string
(*Boolean) Value(i int) bool
(*Boolean) ValueStr(i int) string
*Boolean : github.com/apache/arrow-go/v18/arrow.Array[T]
*Boolean : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Boolean : github.com/goccy/go-json.Marshaler
*Boolean : encoding/json.Marshaler
*Boolean : expvar.Var
*Boolean : fmt.Stringer
func NewBoolean(length int, data *memory.Buffer, nullBitmap *memory.Buffer, nulls int) *Boolean
func NewBooleanData(data arrow.ArrayData) *Boolean
func (*BooleanBuilder).NewBooleanArray() (a *Boolean)
(*BooleanBuilder) Append(v bool)
(*BooleanBuilder) AppendByte(v byte)
(*BooleanBuilder) AppendEmptyValue()
(*BooleanBuilder) AppendEmptyValues(n int)
(*BooleanBuilder) AppendNull()
(*BooleanBuilder) AppendNulls(n int)
(*BooleanBuilder) AppendValueFromString(s string) error
(*BooleanBuilder) AppendValues(v []bool, valid []bool)
Cap returns the total number of elements that can be stored without allocating additional memory.
(*BooleanBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
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.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*BooleanBuilder) SetNull(i int)
(*BooleanBuilder) Type() arrow.DataType
(*BooleanBuilder) Unmarshal(dec *json.Decoder) error
(*BooleanBuilder) UnmarshalJSON(data []byte) error
(*BooleanBuilder) UnmarshalOne(dec *json.Decoder) error
(*BooleanBuilder) UnsafeAppend(v bool)
(*BooleanBuilder) UnsafeAppendBoolToBitmap(isValid bool)
(*BooleanBuilder) Value(i int) bool
*BooleanBuilder : Builder
*BooleanBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*BooleanBuilder : github.com/goccy/go-json.Unmarshaler
*BooleanBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*BooleanBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ListLikeBuilder
*BooleanBuilder : encoding/json.Unmarshaler
func NewBooleanBuilder(mem memory.Allocator) *BooleanBuilder
Builder provides an interface to build arrow arrays.
AppendEmptyValue adds a new zero value of the appropriate type
AppendEmptyValues adds new n zero values of the appropriate type
AppendNull adds a new null value to the array being built.
AppendNulls adds new n null values to the array being built.
AppendValueFromString adds a new value from a string. Inverse of array.ValueStr(i int) string
Cap returns the total number of elements that can be stored
without allocating additional memory.
IsNull returns if a previously appended value at a given index is null or not.
Len returns the number of elements in the array builder.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
SetNull sets the value at index i to null.
Type returns the datatype that this is building
( Builder) Unmarshal(*json.Decoder) error
( Builder) UnmarshalJSON([]byte) error
( Builder) UnmarshalOne(*json.Decoder) error
( Builder) UnsafeAppendBoolToBitmap(bool)
*BinaryBuilder
*BinaryDictionaryBuilder
BinaryLikeBuilder (interface)
*BinaryViewBuilder
*BooleanBuilder
*Date32Builder
*Date64Builder
*DayTimeIntervalBuilder
Decimal128Builder
Decimal256Builder
*DenseUnionBuilder
DictionaryBuilder (interface)
*DurationBuilder
*ExtensionBuilder
*FixedSizeBinaryBuilder
*FixedSizeBinaryDictionaryBuilder
*FixedSizeListBuilder
*Float16Builder
*Float32Builder
*Float64Builder
IndexBuilder
*Int16Builder
*Int32Builder
*Int64Builder
*Int8Builder
*LargeListBuilder
*LargeListViewBuilder
*LargeStringBuilder
*ListBuilder
ListLikeBuilder (interface)
*ListViewBuilder
*MapBuilder
*MonthDayNanoIntervalBuilder
*MonthIntervalBuilder
*NullBuilder
*NullDictionaryBuilder
*RunEndEncodedBuilder
*SparseUnionBuilder
*StringBuilder
StringLikeBuilder (interface)
*StringViewBuilder
*StructBuilder
*Time32Builder
*Time64Builder
*TimestampBuilder
*Uint16Builder
*Uint32Builder
*Uint64Builder
*Uint8Builder
UnionBuilder (interface)
VarLenListLikeBuilder (interface)
*github.com/apache/arrow-go/v18/arrow/extensions.Bool8Builder
*github.com/apache/arrow-go/v18/arrow/extensions.UUIDBuilder
*github.com/apache/arrow-go/v18/arrow/extensions.VariantBuilder
Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
Builder : github.com/goccy/go-json.Unmarshaler
Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
Builder : encoding/json.Unmarshaler
func NewBuilder(mem memory.Allocator, dtype arrow.DataType) Builder
func CustomExtensionBuilder.NewBuilder(memory.Allocator) Builder
func (*ExtensionBuilder).StorageBuilder() Builder
func (*FixedSizeListBuilder).ValueBuilder() Builder
func ListLikeBuilder.ValueBuilder() Builder
func (*MapBuilder).ItemBuilder() Builder
func (*MapBuilder).KeyBuilder() Builder
func (*MapBuilder).ValueBuilder() Builder
func (*RecordBuilder).Field(i int) Builder
func (*RecordBuilder).Fields() []Builder
func (*RunEndEncodedBuilder).ValueBuilder() Builder
func (*StructBuilder).FieldBuilder(i int) Builder
func UnionBuilder.Child(idx int) Builder
func VarLenListLikeBuilder.ValueBuilder() Builder
func github.com/apache/arrow-go/v18/arrow/extensions.(*Bool8Type).NewBuilder(mem memory.Allocator) Builder
func github.com/apache/arrow-go/v18/arrow/extensions.(*UUIDType).NewBuilder(mem memory.Allocator) Builder
func github.com/apache/arrow-go/v18/arrow/extensions.(*VariantType).NewBuilder(mem memory.Allocator) Builder
func NewDenseUnionBuilderWithBuilders(mem memory.Allocator, typ *arrow.DenseUnionType, children []Builder) *DenseUnionBuilder
func NewSparseUnionBuilderWithBuilders(mem memory.Allocator, typ *arrow.SparseUnionType, children []Builder) *SparseUnionBuilder
func UnionBuilder.AppendChild(newChild Builder, fieldName string) (newCode arrow.UnionTypeCode)
func github.com/apache/arrow-go/v18/arrow/scalar.Append(bldr Builder, s scalar.Scalar) error
func github.com/apache/arrow-go/v18/arrow/scalar.AppendSlice(bldr Builder, scalars []scalar.Scalar) error
func github.com/apache/arrow-go/v18/arrow/util.ProtobufMessageFieldReflection.AppendValueOrNull(b Builder, mem memory.Allocator) error
CustomExtensionBuilder is an interface that custom extension types may implement to provide a custom builder
instead of the underlying storage type's builder when array.NewBuilder is called with that type.
( CustomExtensionBuilder) NewBuilder(memory.Allocator) Builder
*github.com/apache/arrow-go/v18/arrow/extensions.Bool8Type
*github.com/apache/arrow-go/v18/arrow/extensions.UUIDType
*github.com/apache/arrow-go/v18/arrow/extensions.VariantType
Data represents the memory and metadata of an Arrow array.
Buffers returns the buffers.
(*Data) Children() []arrow.ArrayData
(*Data) Copy() *Data
DataType returns the DataType of the data.
Dictionary returns the ArrayData object for the dictionary member, or nil
Len returns the length.
NullN returns the number of nulls.
Offset returns the offset.
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.
Reset sets the Data for re-use.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
SetDictionary allows replacing the dictionary for this particular Data object
(*Data) SetNullN(n int)
SizeInBytes returns the size of the Data and any children and/or dictionary in bytes by
recursively examining the nested structures of children and/or dictionary.
The value returned is an upper-bound since offset is not taken into account.
*Data : github.com/apache/arrow-go/v18/arrow.ArrayData
*Data : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
func GetDictArrayData(mem memory.Allocator, valueType arrow.DataType, memoTable hashing.MemoTable, startOffset int) (*Data, error)
func NewData(dtype arrow.DataType, length int, buffers []*memory.Buffer, childData []arrow.ArrayData, nulls, offset int) *Data
func NewDataWithDictionary(dtype arrow.DataType, length int, buffers []*memory.Buffer, nulls, offset int, dict *Data) *Data
func (*Data).Copy() *Data
func NewDataWithDictionary(dtype arrow.DataType, length int, buffers []*memory.Buffer, nulls, offset int, dict *Data) *Data
func (*Timestamp).Reset(data *Data)
(*Date32) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Date32) Date32Values() []arrow.Date32
(*Date32) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Date32) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Date32) Offset() int
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.
(*Date32) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Date32) String() string
(*Date32) Value(i int) arrow.Date32
(*Date32) ValueStr(i int) string
(*Date32) Values() []arrow.Date32
*Date32 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Date32 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Date32 : github.com/goccy/go-json.Marshaler
*Date32 : encoding/json.Marshaler
*Date32 : expvar.Var
*Date32 : fmt.Stringer
func NewDate32Data(data arrow.ArrayData) *Date32
func (*Date32Builder).NewDate32Array() (a *Date32)
(*Date32Builder) Append(v arrow.Date32)
(*Date32Builder) AppendEmptyValue()
(*Date32Builder) AppendEmptyValues(n int)
(*Date32Builder) AppendNull()
(*Date32Builder) AppendNulls(n int)
(*Date32Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Date32Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Date32Builder) SetNull(i int)
(*Date32Builder) Type() arrow.DataType
(*Date32Builder) Unmarshal(dec *json.Decoder) error
(*Date32Builder) UnmarshalJSON(data []byte) error
(*Date32Builder) UnmarshalOne(dec *json.Decoder) error
(*Date32Builder) UnsafeAppend(v arrow.Date32)
(*Date32Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Date32Builder) Value(i int) arrow.Date32
*Date32Builder : Builder
*Date32Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Date32Builder : github.com/goccy/go-json.Unmarshaler
*Date32Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Date32Builder : encoding/json.Unmarshaler
func NewDate32Builder(mem memory.Allocator) *Date32Builder
(*Date32DictionaryBuilder) Append(v arrow.Date32) error
(*Date32DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Date32DictionaryBuilder) AppendEmptyValue()
(*Date32DictionaryBuilder) AppendEmptyValues(n int)
(*Date32DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Date32DictionaryBuilder) AppendNull()
(*Date32DictionaryBuilder) AppendNulls(n int)
(*Date32DictionaryBuilder) AppendValueFromString(s string) error
(*Date32DictionaryBuilder) Cap() int
(*Date32DictionaryBuilder) DictionarySize() int
(*Date32DictionaryBuilder) IndexBuilder() IndexBuilder
(*Date32DictionaryBuilder) InsertDictValues(arr arrValues[arrow.Date32]) (err error)
(*Date32DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Date32DictionaryBuilder) NewArray() arrow.Array
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)
(*Date32DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Date32DictionaryBuilder) Release()
(*Date32DictionaryBuilder) Reserve(n int)
(*Date32DictionaryBuilder) ResetFull()
(*Date32DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Date32DictionaryBuilder) SetNull(i int)
(*Date32DictionaryBuilder) Type() arrow.DataType
(*Date32DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Date32DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Date32DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Date32DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Date32DictionaryBuilder : Builder
*Date32DictionaryBuilder : DictionaryBuilder
*Date32DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Date32DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Date32DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Date32DictionaryBuilder : encoding/json.Unmarshaler
(*Date64) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Date64) Date64Values() []arrow.Date64
(*Date64) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Date64) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Date64) Offset() int
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.
(*Date64) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Date64) String() string
(*Date64) Value(i int) arrow.Date64
(*Date64) ValueStr(i int) string
(*Date64) Values() []arrow.Date64
*Date64 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Date64 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Date64 : github.com/goccy/go-json.Marshaler
*Date64 : encoding/json.Marshaler
*Date64 : expvar.Var
*Date64 : fmt.Stringer
func NewDate64Data(data arrow.ArrayData) *Date64
func (*Date64Builder).NewDate64Array() (a *Date64)
(*Date64Builder) Append(v arrow.Date64)
(*Date64Builder) AppendEmptyValue()
(*Date64Builder) AppendEmptyValues(n int)
(*Date64Builder) AppendNull()
(*Date64Builder) AppendNulls(n int)
(*Date64Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Date64Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Date64Builder) SetNull(i int)
(*Date64Builder) Type() arrow.DataType
(*Date64Builder) Unmarshal(dec *json.Decoder) error
(*Date64Builder) UnmarshalJSON(data []byte) error
(*Date64Builder) UnmarshalOne(dec *json.Decoder) error
(*Date64Builder) UnsafeAppend(v arrow.Date64)
(*Date64Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Date64Builder) Value(i int) arrow.Date64
*Date64Builder : Builder
*Date64Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Date64Builder : github.com/goccy/go-json.Unmarshaler
*Date64Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Date64Builder : encoding/json.Unmarshaler
func NewDate64Builder(mem memory.Allocator) *Date64Builder
(*Date64DictionaryBuilder) Append(v arrow.Date64) error
(*Date64DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Date64DictionaryBuilder) AppendEmptyValue()
(*Date64DictionaryBuilder) AppendEmptyValues(n int)
(*Date64DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Date64DictionaryBuilder) AppendNull()
(*Date64DictionaryBuilder) AppendNulls(n int)
(*Date64DictionaryBuilder) AppendValueFromString(s string) error
(*Date64DictionaryBuilder) Cap() int
(*Date64DictionaryBuilder) DictionarySize() int
(*Date64DictionaryBuilder) IndexBuilder() IndexBuilder
(*Date64DictionaryBuilder) InsertDictValues(arr arrValues[arrow.Date64]) (err error)
(*Date64DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Date64DictionaryBuilder) NewArray() arrow.Array
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)
(*Date64DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Date64DictionaryBuilder) Release()
(*Date64DictionaryBuilder) Reserve(n int)
(*Date64DictionaryBuilder) ResetFull()
(*Date64DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Date64DictionaryBuilder) SetNull(i int)
(*Date64DictionaryBuilder) Type() arrow.DataType
(*Date64DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Date64DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Date64DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Date64DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Date64DictionaryBuilder : Builder
*Date64DictionaryBuilder : DictionaryBuilder
*Date64DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Date64DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Date64DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Date64DictionaryBuilder : encoding/json.Unmarshaler
(*DayTimeDictionaryBuilder) Append(v arrow.DayTimeInterval) error
(*DayTimeDictionaryBuilder) AppendArray(arr arrow.Array) error
(*DayTimeDictionaryBuilder) AppendEmptyValue()
(*DayTimeDictionaryBuilder) AppendEmptyValues(n int)
(*DayTimeDictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*DayTimeDictionaryBuilder) AppendNull()
(*DayTimeDictionaryBuilder) AppendNulls(n int)
(*DayTimeDictionaryBuilder) AppendValueFromString(s string) error
(*DayTimeDictionaryBuilder) Cap() int
(*DayTimeDictionaryBuilder) DictionarySize() int
(*DayTimeDictionaryBuilder) IndexBuilder() IndexBuilder
(*DayTimeDictionaryBuilder) InsertDictValues(arr arrValues[arrow.DayTimeInterval]) (err error)
(*DayTimeDictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*DayTimeDictionaryBuilder) NewArray() arrow.Array
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)
(*DayTimeDictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*DayTimeDictionaryBuilder) Release()
(*DayTimeDictionaryBuilder) Reserve(n int)
(*DayTimeDictionaryBuilder) ResetFull()
(*DayTimeDictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*DayTimeDictionaryBuilder) SetNull(i int)
(*DayTimeDictionaryBuilder) Type() arrow.DataType
(*DayTimeDictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*DayTimeDictionaryBuilder) UnmarshalJSON(data []byte) error
(*DayTimeDictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*DayTimeDictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*DayTimeDictionaryBuilder : Builder
*DayTimeDictionaryBuilder : DictionaryBuilder
*DayTimeDictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*DayTimeDictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*DayTimeDictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*DayTimeDictionaryBuilder : encoding/json.Unmarshaler
A type which represents an immutable sequence of arrow.DayTimeInterval values.
(*DayTimeInterval) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*DayTimeInterval) DayTimeIntervalValues() []arrow.DayTimeInterval
(*DayTimeInterval) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
MarshalJSON will marshal this array to JSON as an array of objects,
consisting of the form {"days": #, "milliseconds": #} for each element.
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*DayTimeInterval) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*DayTimeInterval) String() string
(*DayTimeInterval) Value(i int) arrow.DayTimeInterval
(*DayTimeInterval) ValueStr(i int) string
*DayTimeInterval : github.com/apache/arrow-go/v18/arrow.Array[T]
*DayTimeInterval : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*DayTimeInterval : github.com/goccy/go-json.Marshaler
*DayTimeInterval : encoding/json.Marshaler
*DayTimeInterval : expvar.Var
*DayTimeInterval : fmt.Stringer
func NewDayTimeIntervalData(data arrow.ArrayData) *DayTimeInterval
func (*DayTimeIntervalBuilder).NewDayTimeIntervalArray() (a *DayTimeInterval)
(*DayTimeIntervalBuilder) Append(v arrow.DayTimeInterval)
(*DayTimeIntervalBuilder) AppendEmptyValue()
(*DayTimeIntervalBuilder) AppendEmptyValues(n int)
(*DayTimeIntervalBuilder) AppendNull()
(*DayTimeIntervalBuilder) AppendNulls(n int)
(*DayTimeIntervalBuilder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*DayTimeIntervalBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*DayTimeIntervalBuilder) SetNull(i int)
(*DayTimeIntervalBuilder) Type() arrow.DataType
(*DayTimeIntervalBuilder) Unmarshal(dec *json.Decoder) 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": #}
(*DayTimeIntervalBuilder) UnmarshalOne(dec *json.Decoder) error
(*DayTimeIntervalBuilder) UnsafeAppend(v arrow.DayTimeInterval)
(*DayTimeIntervalBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*DayTimeIntervalBuilder : Builder
*DayTimeIntervalBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*DayTimeIntervalBuilder : github.com/goccy/go-json.Unmarshaler
*DayTimeIntervalBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*DayTimeIntervalBuilder : encoding/json.Unmarshaler
func NewDayTimeIntervalBuilder(mem memory.Allocator) *DayTimeIntervalBuilder
(*Decimal128) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Decimal128) GetOneForMarshal(i int) any
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Decimal128) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Decimal128) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Decimal128) String() string
(*Decimal128) Value(i int) decimal.Decimal128
(*Decimal128) ValueStr(i int) string
(*Decimal128) Values() []decimal.Decimal128
*Decimal128 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Decimal128 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Decimal128 : github.com/goccy/go-json.Marshaler
*Decimal128 : encoding/json.Marshaler
*Decimal128 : expvar.Var
*Decimal128 : fmt.Stringer
( Decimal128Builder) Append(v decimal.Decimal128)
( Decimal128Builder) AppendEmptyValue()
( Decimal128Builder) AppendEmptyValues(n int)
( Decimal128Builder) AppendNull()
( Decimal128Builder) AppendNulls(n int)
( Decimal128Builder) AppendValueFromString(s string) error
( Decimal128Builder) AppendValues(v []decimal.Decimal128, valid []bool)
Cap returns the total number of elements that can be stored without allocating additional memory.
( Decimal128Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
( Decimal128Builder) NewArray() arrow.Array
(*Decimal128Builder) NewDecimal128Array() *Decimal128
( Decimal128Builder) NewDecimalArray() (a *baseDecimal[decimal.Decimal128])
NullN returns the number of null values in the array builder.
( Decimal128Builder) Release()
( Decimal128Builder) Reserve(n int)
( Decimal128Builder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( Decimal128Builder) SetNull(i int)
( Decimal128Builder) Type() arrow.DataType
( Decimal128Builder) Unmarshal(dec *json.Decoder) error
( Decimal128Builder) UnmarshalJSON(data []byte) error
( Decimal128Builder) UnmarshalOne(dec *json.Decoder) error
( Decimal128Builder) UnsafeAppend(v decimal.Decimal128)
( Decimal128Builder) UnsafeAppendBoolToBitmap(isValid bool)
Decimal128Builder : Builder
Decimal128Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
Decimal128Builder : github.com/goccy/go-json.Unmarshaler
Decimal128Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
Decimal128Builder : encoding/json.Unmarshaler
func NewDecimal128Builder(mem memory.Allocator, dtype *arrow.Decimal128Type) *Decimal128Builder
(*Decimal128DictionaryBuilder) Append(v decimal.Decimal128) error
(*Decimal128DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Decimal128DictionaryBuilder) AppendEmptyValue()
(*Decimal128DictionaryBuilder) AppendEmptyValues(n int)
(*Decimal128DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Decimal128DictionaryBuilder) AppendNull()
(*Decimal128DictionaryBuilder) AppendNulls(n int)
(*Decimal128DictionaryBuilder) AppendValueFromString(s string) error
(*Decimal128DictionaryBuilder) Cap() int
(*Decimal128DictionaryBuilder) DictionarySize() int
(*Decimal128DictionaryBuilder) IndexBuilder() IndexBuilder
(*Decimal128DictionaryBuilder) InsertDictValues(arr arrValues[decimal.Decimal128]) (err error)
(*Decimal128DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Decimal128DictionaryBuilder) NewArray() arrow.Array
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)
(*Decimal128DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Decimal128DictionaryBuilder) Release()
(*Decimal128DictionaryBuilder) Reserve(n int)
(*Decimal128DictionaryBuilder) ResetFull()
(*Decimal128DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Decimal128DictionaryBuilder) SetNull(i int)
(*Decimal128DictionaryBuilder) Type() arrow.DataType
(*Decimal128DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Decimal128DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Decimal128DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Decimal128DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Decimal128DictionaryBuilder : Builder
*Decimal128DictionaryBuilder : DictionaryBuilder
*Decimal128DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Decimal128DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Decimal128DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Decimal128DictionaryBuilder : encoding/json.Unmarshaler
(*Decimal256) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Decimal256) GetOneForMarshal(i int) any
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Decimal256) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Decimal256) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Decimal256) String() string
(*Decimal256) Value(i int) decimal.Decimal256
(*Decimal256) ValueStr(i int) string
(*Decimal256) Values() []decimal.Decimal256
*Decimal256 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Decimal256 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Decimal256 : github.com/goccy/go-json.Marshaler
*Decimal256 : encoding/json.Marshaler
*Decimal256 : expvar.Var
*Decimal256 : fmt.Stringer
( Decimal256Builder) Append(v decimal.Decimal256)
( Decimal256Builder) AppendEmptyValue()
( Decimal256Builder) AppendEmptyValues(n int)
( Decimal256Builder) AppendNull()
( Decimal256Builder) AppendNulls(n int)
( Decimal256Builder) AppendValueFromString(s string) error
( Decimal256Builder) AppendValues(v []decimal.Decimal256, valid []bool)
Cap returns the total number of elements that can be stored without allocating additional memory.
( Decimal256Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
( Decimal256Builder) NewArray() arrow.Array
(*Decimal256Builder) NewDecimal256Array() *Decimal256
( Decimal256Builder) NewDecimalArray() (a *baseDecimal[decimal.Decimal256])
NullN returns the number of null values in the array builder.
( Decimal256Builder) Release()
( Decimal256Builder) Reserve(n int)
( Decimal256Builder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( Decimal256Builder) SetNull(i int)
( Decimal256Builder) Type() arrow.DataType
( Decimal256Builder) Unmarshal(dec *json.Decoder) error
( Decimal256Builder) UnmarshalJSON(data []byte) error
( Decimal256Builder) UnmarshalOne(dec *json.Decoder) error
( Decimal256Builder) UnsafeAppend(v decimal.Decimal256)
( Decimal256Builder) UnsafeAppendBoolToBitmap(isValid bool)
Decimal256Builder : Builder
Decimal256Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
Decimal256Builder : github.com/goccy/go-json.Unmarshaler
Decimal256Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
Decimal256Builder : encoding/json.Unmarshaler
func NewDecimal256Builder(mem memory.Allocator, dtype *arrow.Decimal256Type) *Decimal256Builder
(*Decimal256DictionaryBuilder) Append(v decimal.Decimal256) error
(*Decimal256DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Decimal256DictionaryBuilder) AppendEmptyValue()
(*Decimal256DictionaryBuilder) AppendEmptyValues(n int)
(*Decimal256DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Decimal256DictionaryBuilder) AppendNull()
(*Decimal256DictionaryBuilder) AppendNulls(n int)
(*Decimal256DictionaryBuilder) AppendValueFromString(s string) error
(*Decimal256DictionaryBuilder) Cap() int
(*Decimal256DictionaryBuilder) DictionarySize() int
(*Decimal256DictionaryBuilder) IndexBuilder() IndexBuilder
(*Decimal256DictionaryBuilder) InsertDictValues(arr arrValues[decimal.Decimal256]) (err error)
(*Decimal256DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Decimal256DictionaryBuilder) NewArray() arrow.Array
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)
(*Decimal256DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Decimal256DictionaryBuilder) Release()
(*Decimal256DictionaryBuilder) Reserve(n int)
(*Decimal256DictionaryBuilder) ResetFull()
(*Decimal256DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Decimal256DictionaryBuilder) SetNull(i int)
(*Decimal256DictionaryBuilder) Type() arrow.DataType
(*Decimal256DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Decimal256DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Decimal256DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Decimal256DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Decimal256DictionaryBuilder : Builder
*Decimal256DictionaryBuilder : DictionaryBuilder
*Decimal256DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Decimal256DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Decimal256DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Decimal256DictionaryBuilder : encoding/json.Unmarshaler
(*Decimal32) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Decimal32) GetOneForMarshal(i int) any
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Decimal32) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Decimal32) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Decimal32) String() string
(*Decimal32) Value(i int) decimal.Decimal32
(*Decimal32) ValueStr(i int) string
(*Decimal32) Values() []decimal.Decimal32
*Decimal32 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Decimal32 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Decimal32 : github.com/goccy/go-json.Marshaler
*Decimal32 : encoding/json.Marshaler
*Decimal32 : expvar.Var
*Decimal32 : fmt.Stringer
(*Decimal32Builder) Append(v decimal.Decimal32)
(*Decimal32Builder) AppendEmptyValue()
(*Decimal32Builder) AppendEmptyValues(n int)
(*Decimal32Builder) AppendNull()
(*Decimal32Builder) AppendNulls(n int)
(*Decimal32Builder) AppendValueFromString(s string) error
(*Decimal32Builder) AppendValues(v []decimal.Decimal32, valid []bool)
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Decimal32Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Decimal32Builder) NewArray() arrow.Array
(*Decimal32Builder) NewDecimalArray() (a *baseDecimal[decimal.Decimal32])
NullN returns the number of null values in the array builder.
(*Decimal32Builder) Release()
(*Decimal32Builder) Reserve(n int)
(*Decimal32Builder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Decimal32Builder) SetNull(i int)
(*Decimal32Builder) Type() arrow.DataType
(*Decimal32Builder) Unmarshal(dec *json.Decoder) error
(*Decimal32Builder) UnmarshalJSON(data []byte) error
(*Decimal32Builder) UnmarshalOne(dec *json.Decoder) error
(*Decimal32Builder) UnsafeAppend(v decimal.Decimal32)
(*Decimal32Builder) UnsafeAppendBoolToBitmap(isValid bool)
*Decimal32Builder : Builder
*Decimal32Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Decimal32Builder : github.com/goccy/go-json.Unmarshaler
*Decimal32Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Decimal32Builder : encoding/json.Unmarshaler
(*Decimal32DictionaryBuilder) Append(v decimal.Decimal32) error
(*Decimal32DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Decimal32DictionaryBuilder) AppendEmptyValue()
(*Decimal32DictionaryBuilder) AppendEmptyValues(n int)
(*Decimal32DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Decimal32DictionaryBuilder) AppendNull()
(*Decimal32DictionaryBuilder) AppendNulls(n int)
(*Decimal32DictionaryBuilder) AppendValueFromString(s string) error
(*Decimal32DictionaryBuilder) Cap() int
(*Decimal32DictionaryBuilder) DictionarySize() int
(*Decimal32DictionaryBuilder) IndexBuilder() IndexBuilder
(*Decimal32DictionaryBuilder) InsertDictValues(arr arrValues[decimal.Decimal32]) (err error)
(*Decimal32DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Decimal32DictionaryBuilder) NewArray() arrow.Array
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)
(*Decimal32DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Decimal32DictionaryBuilder) Release()
(*Decimal32DictionaryBuilder) Reserve(n int)
(*Decimal32DictionaryBuilder) ResetFull()
(*Decimal32DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Decimal32DictionaryBuilder) SetNull(i int)
(*Decimal32DictionaryBuilder) Type() arrow.DataType
(*Decimal32DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Decimal32DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Decimal32DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Decimal32DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Decimal32DictionaryBuilder : Builder
*Decimal32DictionaryBuilder : DictionaryBuilder
*Decimal32DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Decimal32DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Decimal32DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Decimal32DictionaryBuilder : encoding/json.Unmarshaler
(*Decimal64) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Decimal64) GetOneForMarshal(i int) any
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Decimal64) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Decimal64) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Decimal64) String() string
(*Decimal64) Value(i int) decimal.Decimal64
(*Decimal64) ValueStr(i int) string
(*Decimal64) Values() []decimal.Decimal64
*Decimal64 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Decimal64 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Decimal64 : github.com/goccy/go-json.Marshaler
*Decimal64 : encoding/json.Marshaler
*Decimal64 : expvar.Var
*Decimal64 : fmt.Stringer
(*Decimal64Builder) Append(v decimal.Decimal64)
(*Decimal64Builder) AppendEmptyValue()
(*Decimal64Builder) AppendEmptyValues(n int)
(*Decimal64Builder) AppendNull()
(*Decimal64Builder) AppendNulls(n int)
(*Decimal64Builder) AppendValueFromString(s string) error
(*Decimal64Builder) AppendValues(v []decimal.Decimal64, valid []bool)
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Decimal64Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Decimal64Builder) NewArray() arrow.Array
(*Decimal64Builder) NewDecimalArray() (a *baseDecimal[decimal.Decimal64])
NullN returns the number of null values in the array builder.
(*Decimal64Builder) Release()
(*Decimal64Builder) Reserve(n int)
(*Decimal64Builder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Decimal64Builder) SetNull(i int)
(*Decimal64Builder) Type() arrow.DataType
(*Decimal64Builder) Unmarshal(dec *json.Decoder) error
(*Decimal64Builder) UnmarshalJSON(data []byte) error
(*Decimal64Builder) UnmarshalOne(dec *json.Decoder) error
(*Decimal64Builder) UnsafeAppend(v decimal.Decimal64)
(*Decimal64Builder) UnsafeAppendBoolToBitmap(isValid bool)
*Decimal64Builder : Builder
*Decimal64Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Decimal64Builder : github.com/goccy/go-json.Unmarshaler
*Decimal64Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Decimal64Builder : encoding/json.Unmarshaler
(*Decimal64DictionaryBuilder) Append(v decimal.Decimal64) error
(*Decimal64DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Decimal64DictionaryBuilder) AppendEmptyValue()
(*Decimal64DictionaryBuilder) AppendEmptyValues(n int)
(*Decimal64DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Decimal64DictionaryBuilder) AppendNull()
(*Decimal64DictionaryBuilder) AppendNulls(n int)
(*Decimal64DictionaryBuilder) AppendValueFromString(s string) error
(*Decimal64DictionaryBuilder) Cap() int
(*Decimal64DictionaryBuilder) DictionarySize() int
(*Decimal64DictionaryBuilder) IndexBuilder() IndexBuilder
(*Decimal64DictionaryBuilder) InsertDictValues(arr arrValues[decimal.Decimal64]) (err error)
(*Decimal64DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Decimal64DictionaryBuilder) NewArray() arrow.Array
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)
(*Decimal64DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Decimal64DictionaryBuilder) Release()
(*Decimal64DictionaryBuilder) Reserve(n int)
(*Decimal64DictionaryBuilder) ResetFull()
(*Decimal64DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Decimal64DictionaryBuilder) SetNull(i int)
(*Decimal64DictionaryBuilder) Type() arrow.DataType
(*Decimal64DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Decimal64DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Decimal64DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Decimal64DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Decimal64DictionaryBuilder : Builder
*Decimal64DictionaryBuilder : DictionaryBuilder
*Decimal64DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Decimal64DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Decimal64DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Decimal64DictionaryBuilder : encoding/json.Unmarshaler
DenseUnion represents an array where each logical value is taken from
a single child, at a specific offset. A buffer of 8-bit type ids
indicates which child a given logical value is to be taken from and
a buffer of 32-bit offsets indicating which physical position in the
given child array has the logical value for that index.
Unlike a sparse union, a dense union allows encoding only the child values
which are actually referred to by the union array. This is counterbalanced
by the additional footprint of the offsets buffer, and the additional
indirection cost when looking up values.
Unlike most other arrays, unions do not have a top-level validity bitmap.
(*DenseUnion) ChildID(i int) int
(*DenseUnion) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*DenseUnion) Field(pos int) (result arrow.Array)
(*DenseUnion) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*DenseUnion) MarshalJSON() ([]byte, error)
(*DenseUnion) Mode() arrow.UnionMode
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*DenseUnion) NumFields() int
(*DenseUnion) Offset() int
(*DenseUnion) RawTypeCodes() []arrow.UnionTypeCode
(*DenseUnion) RawValueOffsets() []int32
(*DenseUnion) Release()
(*DenseUnion) Retain()
(*DenseUnion) String() string
(*DenseUnion) TypeCode(i int) arrow.UnionTypeCode
(*DenseUnion) TypeCodes() *memory.Buffer
(*DenseUnion) UnionType() arrow.UnionType
(*DenseUnion) Validate() error
(*DenseUnion) ValidateFull() error
(*DenseUnion) ValueOffset(i int) int32
(*DenseUnion) ValueOffsets() *memory.Buffer
(*DenseUnion) ValueStr(i int) string
*DenseUnion : Union
*DenseUnion : github.com/apache/arrow-go/v18/arrow.Array[T]
*DenseUnion : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*DenseUnion : github.com/goccy/go-json.Marshaler
*DenseUnion : encoding/json.Marshaler
*DenseUnion : expvar.Var
*DenseUnion : fmt.Stringer
func NewDenseUnion(dt *arrow.DenseUnionType, length int, children []arrow.Array, typeIDs, valueOffsets *memory.Buffer, offset int) *DenseUnion
func NewDenseUnionData(data arrow.ArrayData) *DenseUnion
func NewDenseUnionFromArrays(typeIDs, offsets arrow.Array, children []arrow.Array, codes ...arrow.UnionTypeCode) (*DenseUnion, error)
func NewDenseUnionFromArraysWithFieldCodes(typeIDs, offsets arrow.Array, children []arrow.Array, fields []string, codes []arrow.UnionTypeCode) (*DenseUnion, error)
func NewDenseUnionFromArraysWithFields(typeIDs, offsets arrow.Array, children []arrow.Array, fields []string) (*DenseUnion, error)
func (*DenseUnionBuilder).NewDenseUnionArray() (a *DenseUnion)
DenseUnionBuilder is used to build a Dense Union array using the Append
methods. You can also add new types to the union on the fly by using
AppendChild.
Append appends the necessary offset and type code to the builder
and must be followed up with an append to the appropriate child builder
( DenseUnionBuilder) AppendChild(newChild Builder, fieldName string) arrow.UnionTypeCode
AppendEmptyValue only appends an empty value arbitrarily to the first child,
and then uses that offset to identify the value.
AppendEmptyValues, like AppendNulls, will only append a single empty value
(implementation defined) to the first child arbitrarily, and then point
at that value using the offsets n times. That makes this more efficient
than calling AppendEmptyValue multiple times.
AppendNull will only append a null value arbitrarily to the first child
and use that offset for this element of the array.
AppendNulls will only append a single null arbitrarily to the first child
and use the same offset multiple times to point to it. The result is that
for a DenseUnion this is more efficient than calling AppendNull multiple
times in a loop
(*DenseUnionBuilder) AppendValueFromString(s string) error
Cap returns the total number of elements that can be stored without allocating additional memory.
( DenseUnionBuilder) Child(idx int) Builder
( DenseUnionBuilder) IsNull(i int) bool
Len returns the current number of elements in the builder.
( DenseUnionBuilder) Mode() arrow.UnionMode
(*DenseUnionBuilder) NewArray() arrow.Array
(*DenseUnionBuilder) NewDenseUnionArray() (a *DenseUnion)
NullN returns the number of null values in the array builder.
( DenseUnionBuilder) NumChildren() int
(*DenseUnionBuilder) Release()
(*DenseUnionBuilder) Reserve(n int)
(*DenseUnionBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( DenseUnionBuilder) SetNull(i int)
( DenseUnionBuilder) Type() arrow.DataType
(*DenseUnionBuilder) Unmarshal(dec *json.Decoder) error
(*DenseUnionBuilder) UnmarshalJSON(data []byte) (err error)
(*DenseUnionBuilder) UnmarshalOne(dec *json.Decoder) error
( DenseUnionBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*DenseUnionBuilder : Builder
*DenseUnionBuilder : UnionBuilder
*DenseUnionBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*DenseUnionBuilder : github.com/goccy/go-json.Unmarshaler
*DenseUnionBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*DenseUnionBuilder : encoding/json.Unmarshaler
func NewDenseUnionBuilder(mem memory.Allocator, typ *arrow.DenseUnionType) *DenseUnionBuilder
func NewDenseUnionBuilderWithBuilders(mem memory.Allocator, typ *arrow.DenseUnionType, children []Builder) *DenseUnionBuilder
func NewEmptyDenseUnionBuilder(mem memory.Allocator) *DenseUnionBuilder
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.
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.
(*Dictionary) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
Dictionary returns the values array that makes up the dictionary for this
array.
(*Dictionary) GetOneForMarshal(i int) interface{}
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))
Indices returns the underlying array of indices as it's own array
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Dictionary) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Dictionary) Offset() int
(*Dictionary) Release()
(*Dictionary) Retain()
(*Dictionary) String() string
(*Dictionary) ValueStr(i int) string
*Dictionary : github.com/apache/arrow-go/v18/arrow.Array[T]
*Dictionary : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Dictionary : github.com/goccy/go-json.Marshaler
*Dictionary : encoding/json.Marshaler
*Dictionary : expvar.Var
*Dictionary : fmt.Stringer
func NewDictionaryArray(typ arrow.DataType, indices, dict arrow.Array) *Dictionary
func NewDictionaryData(data arrow.ArrayData) *Dictionary
func NewValidatedDictionaryArray(typ *arrow.DictionaryType, indices, dict arrow.Array) (*Dictionary, error)
func DictionaryBuilder.NewDictionaryArray() *Dictionary
func (*NullDictionaryBuilder).NewDictionaryArray() *Dictionary
func NewDictWrapper[T](dict *Dictionary) (arrow.TypedArray[T], error)
func (*Dictionary).CanCompareIndices(other *Dictionary) bool
func github.com/polarsignals/frostdb/pqarrow/arrowutils.TakeDictColumn(ctx context.Context, a *Dictionary, idx int, arr []arrow.Array, indices *Int32) error
func github.com/polarsignals/frostdb/query/physicalplan.BinaryDictionaryArrayScalarRegexMatch(dict *Dictionary, left *Binary, right *regexp.Regexp) (*physicalplan.Bitmap, error)
func github.com/polarsignals/frostdb/query/physicalplan.BinaryDictionaryArrayScalarRegexNotMatch(dict *Dictionary, left *Binary, right *regexp.Regexp) (*physicalplan.Bitmap, error)
func github.com/polarsignals/frostdb/query/physicalplan.DictionaryArrayScalarContains(left *Dictionary, right scalar.Scalar, not bool) (*physicalplan.Bitmap, error)
func github.com/polarsignals/frostdb/query/physicalplan.DictionaryArrayScalarEqual(left *Dictionary, right scalar.Scalar) (*physicalplan.Bitmap, error)
func github.com/polarsignals/frostdb/query/physicalplan.DictionaryArrayScalarNotEqual(left *Dictionary, right scalar.Scalar) (*physicalplan.Bitmap, error)
( DictionaryBuilder) AppendArray(arrow.Array) error
AppendEmptyValue adds a new zero value of the appropriate type
AppendEmptyValues adds new n zero values of the appropriate type
( DictionaryBuilder) AppendIndices([]int, []bool)
AppendNull adds a new null value to the array being built.
AppendNulls adds new n null values to the array being built.
AppendValueFromString adds a new value from a string. Inverse of array.ValueStr(i int) string
Cap returns the total number of elements that can be stored
without allocating additional memory.
( DictionaryBuilder) DictionarySize() int
IsNull returns if a previously appended value at a given index is null or not.
Len returns the number of elements in the array builder.
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.
( DictionaryBuilder) NewDelta() (indices, delta arrow.Array, err error)
( DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
( DictionaryBuilder) ResetFull()
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
SetNull sets the value at index i to null.
Type returns the datatype that this is building
( DictionaryBuilder) Unmarshal(*json.Decoder) error
( DictionaryBuilder) UnmarshalJSON([]byte) error
( DictionaryBuilder) UnmarshalOne(*json.Decoder) error
( DictionaryBuilder) UnsafeAppendBoolToBitmap(bool)
*BinaryDictionaryBuilder
*FixedSizeBinaryDictionaryBuilder
*NullDictionaryBuilder
DictionaryBuilder : Builder
DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
DictionaryBuilder : encoding/json.Unmarshaler
func NewDictionaryBuilder(mem memory.Allocator, dt *arrow.DictionaryType) DictionaryBuilder
func NewDictionaryBuilderWithDict(mem memory.Allocator, dt *arrow.DictionaryType, init arrow.Array) DictionaryBuilder
DictionaryUnifier defines the interface used for unifying, and optionally producing
transposition maps for, multiple dictionary arrays incrementally.
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.
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.
Release should be called to clean up any allocated scratch memo-table used
for building the unified dictionary.
Unify adds the provided array of dictionary values to be unified.
UnifyAndTranspose adds the provided array of dictionary values,
just like Unify but returns an allocated buffer containing a mapping
to transpose dictionary indices.
func NewBinaryDictionaryUnifier(alloc memory.Allocator) DictionaryUnifier
func NewDictionaryUnifier(alloc memory.Allocator, valueType arrow.DataType) (DictionaryUnifier, error)
(*Duration) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Duration) DurationValues() []arrow.Duration
(*Duration) GetOneForMarshal(i int) any
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Duration) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Duration) Offset() int
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.
(*Duration) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Duration) String() string
(*Duration) Value(i int) arrow.Duration
(*Duration) ValueStr(i int) string
(*Duration) Values() []arrow.Duration
*Duration : github.com/apache/arrow-go/v18/arrow.Array[T]
*Duration : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Duration : github.com/goccy/go-json.Marshaler
*Duration : encoding/json.Marshaler
*Duration : expvar.Var
*Duration : fmt.Stringer
func NewDurationData(data arrow.ArrayData) *Duration
func (*DurationBuilder).NewDurationArray() (a *Duration)
(*DurationBuilder) Append(v arrow.Duration)
(*DurationBuilder) AppendEmptyValue()
(*DurationBuilder) AppendEmptyValues(n int)
(*DurationBuilder) AppendNull()
(*DurationBuilder) AppendNulls(n int)
(*DurationBuilder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*DurationBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*DurationBuilder) SetNull(i int)
(*DurationBuilder) Type() arrow.DataType
(*DurationBuilder) Unmarshal(dec *json.Decoder) error
(*DurationBuilder) UnmarshalJSON(data []byte) error
(*DurationBuilder) UnmarshalOne(dec *json.Decoder) error
(*DurationBuilder) UnsafeAppend(v arrow.Duration)
(*DurationBuilder) UnsafeAppendBoolToBitmap(isValid bool)
(*DurationBuilder) Value(i int) arrow.Duration
*DurationBuilder : Builder
*DurationBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*DurationBuilder : github.com/goccy/go-json.Unmarshaler
*DurationBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*DurationBuilder : encoding/json.Unmarshaler
func NewDurationBuilder(mem memory.Allocator, dtype *arrow.DurationType) *DurationBuilder
(*DurationDictionaryBuilder) Append(v arrow.Duration) error
(*DurationDictionaryBuilder) AppendArray(arr arrow.Array) error
(*DurationDictionaryBuilder) AppendEmptyValue()
(*DurationDictionaryBuilder) AppendEmptyValues(n int)
(*DurationDictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*DurationDictionaryBuilder) AppendNull()
(*DurationDictionaryBuilder) AppendNulls(n int)
(*DurationDictionaryBuilder) AppendValueFromString(s string) error
(*DurationDictionaryBuilder) Cap() int
(*DurationDictionaryBuilder) DictionarySize() int
(*DurationDictionaryBuilder) IndexBuilder() IndexBuilder
(*DurationDictionaryBuilder) InsertDictValues(arr arrValues[arrow.Duration]) (err error)
(*DurationDictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*DurationDictionaryBuilder) NewArray() arrow.Array
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)
(*DurationDictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*DurationDictionaryBuilder) Release()
(*DurationDictionaryBuilder) Reserve(n int)
(*DurationDictionaryBuilder) ResetFull()
(*DurationDictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*DurationDictionaryBuilder) SetNull(i int)
(*DurationDictionaryBuilder) Type() arrow.DataType
(*DurationDictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*DurationDictionaryBuilder) UnmarshalJSON(data []byte) error
(*DurationDictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*DurationDictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*DurationDictionaryBuilder : Builder
*DurationDictionaryBuilder : DictionaryBuilder
*DurationDictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*DurationDictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*DurationDictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*DurationDictionaryBuilder : encoding/json.Unmarshaler
Edits is a slice of Edit structs that represents an edit script to compare two arrays.
When applied to the base array, it produces the target array.
Each element of "insert" determines whether an element was inserted into (true)
or deleted from (false) base. Each insertion or deletion is followed by a run of
elements which are unchanged from base to target; the length of this run is stored
in RunLength. (Note that the edit script begins and ends with a run of shared
elements but both fields of the struct must have the same length. To accommodate this
the first element of "insert" should be ignored.)
For example for base "hlloo" and target "hello", the edit script would be
[
{"insert": false, "run_length": 1}, // leading run of length 1 ("h")
{"insert": true, "run_length": 3}, // insert("e") then a run of length 3 ("llo")
{"insert": false, "run_length": 0} // delete("o") then an empty run
]
String returns a simple string representation of the edit script.
UnifiedDiff returns a string representation of the diff of base and target in Unified Diff format.
Edits : expvar.Var
Edits : fmt.Stringer
func Diff(base, target arrow.Array) (edits Edits, err error)
EqualOption is a functional option type used to configure how Records and Arrays are compared.
func WithAbsTolerance(atol float64) EqualOption
func WithNaNsEqual(v bool) EqualOption
func WithUnorderedMapKeys(v bool) EqualOption
func ApproxEqual(left, right arrow.Array, opts ...EqualOption) bool
func ChunkedApproxEqual(left, right *arrow.Chunked, opts ...EqualOption) bool
func RecordApproxEqual(left, right arrow.RecordBatch, opts ...EqualOption) bool
func SliceApproxEqual(left arrow.Array, lbeg, lend int64, right arrow.Array, rbeg, rend int64, opts ...EqualOption) bool
func TableApproxEqual(left, right arrow.Table, opts ...EqualOption) bool
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.
( ExtensionArray) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
ExtensionType returns the datatype as per calling DataType(), but
already cast to ExtensionType
Get single value to be marshalled with `json.Marshal`
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
( ExtensionArray) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
Storage returns the underlying storage array for this array.
( ExtensionArray) String() string
ValueStr returns the value at index as a string.
*ExtensionArrayBase
*github.com/apache/arrow-go/v18/arrow/extensions.Bool8Array
*github.com/apache/arrow-go/v18/arrow/extensions.JSONArray
*github.com/apache/arrow-go/v18/arrow/extensions.OpaqueArray
*github.com/apache/arrow-go/v18/arrow/extensions.UUIDArray
*github.com/apache/arrow-go/v18/arrow/extensions.VariantArray
ExtensionArray : github.com/apache/arrow-go/v18/arrow.Array[T]
ExtensionArray : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
ExtensionArray : github.com/goccy/go-json.Marshaler
ExtensionArray : encoding/json.Marshaler
ExtensionArray : expvar.Var
ExtensionArray : fmt.Stringer
func NewExtensionData(data arrow.ArrayData) ExtensionArray
func (*ExtensionBuilder).NewExtensionArray() ExtensionArray
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
}
(*ExtensionArrayBase) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
ExtensionType returns the same thing as DataType, just already casted
to an ExtensionType interface for convenience.
(*ExtensionArrayBase) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*ExtensionArrayBase) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*ExtensionArrayBase) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
Storage returns the underlying storage array
(*ExtensionArrayBase) String() string
ValueStr returns the value at index i as a string.
This needs to be implemented by the extension array type.
*ExtensionArrayBase : ExtensionArray
*ExtensionArrayBase : github.com/apache/arrow-go/v18/arrow.Array[T]
*ExtensionArrayBase : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*ExtensionArrayBase : github.com/goccy/go-json.Marshaler
*ExtensionArrayBase : encoding/json.Marshaler
*ExtensionArrayBase : expvar.Var
*ExtensionArrayBase : fmt.Stringer
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.
Builder Builder
AppendEmptyValue adds a new zero value of the appropriate type
AppendEmptyValues adds new n zero values of the appropriate type
AppendNull adds a new null value to the array being built.
AppendNulls adds new n null values to the array being built.
AppendValueFromString adds a new value from a string. Inverse of array.ValueStr(i int) string
Cap returns the total number of elements that can be stored
without allocating additional memory.
IsNull returns if a previously appended value at a given index is null or not.
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
SetNull sets the value at index i to null.
StorageBuilder returns the builder for the underlying storage type.
(*ExtensionBuilder) Type() arrow.DataType
( ExtensionBuilder) Unmarshal(*json.Decoder) error
( ExtensionBuilder) UnmarshalJSON([]byte) error
( ExtensionBuilder) UnmarshalOne(*json.Decoder) error
( ExtensionBuilder) UnsafeAppendBoolToBitmap(bool)
*ExtensionBuilder : Builder
ExtensionBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
ExtensionBuilder : github.com/goccy/go-json.Unmarshaler
*ExtensionBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
ExtensionBuilder : encoding/json.Unmarshaler
func NewExtensionBuilder(mem memory.Allocator, dt arrow.ExtensionType) *ExtensionBuilder
A type which represents an immutable sequence of fixed-length binary strings.
(*FixedSizeBinary) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*FixedSizeBinary) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*FixedSizeBinary) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*FixedSizeBinary) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*FixedSizeBinary) String() string
Value returns the fixed-size slice at index i. This value should not be mutated.
(*FixedSizeBinary) ValueStr(i int) string
*FixedSizeBinary : github.com/apache/arrow-go/v18/arrow.Array[T]
*FixedSizeBinary : github.com/apache/arrow-go/v18/arrow.TypedArray[[]byte]
*FixedSizeBinary : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*FixedSizeBinary : github.com/goccy/go-json.Marshaler
*FixedSizeBinary : encoding/json.Marshaler
*FixedSizeBinary : expvar.Var
*FixedSizeBinary : fmt.Stringer
func NewFixedSizeBinaryData(data arrow.ArrayData) *FixedSizeBinary
func (*FixedSizeBinaryBuilder).NewFixedSizeBinaryArray() (a *FixedSizeBinary)
func (*FixedSizeBinaryDictionaryBuilder).InsertDictValues(arr *FixedSizeBinary) (err error)
A FixedSizeBinaryBuilder is used to build a FixedSizeBinary array using the Append methods.
(*FixedSizeBinaryBuilder) Append(v []byte)
(*FixedSizeBinaryBuilder) AppendEmptyValue()
(*FixedSizeBinaryBuilder) AppendEmptyValues(n int)
(*FixedSizeBinaryBuilder) AppendNull()
(*FixedSizeBinaryBuilder) AppendNulls(n int)
(*FixedSizeBinaryBuilder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*FixedSizeBinaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
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.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*FixedSizeBinaryBuilder) SetNull(i int)
(*FixedSizeBinaryBuilder) Type() arrow.DataType
(*FixedSizeBinaryBuilder) Unmarshal(dec *json.Decoder) error
(*FixedSizeBinaryBuilder) UnmarshalJSON(data []byte) error
(*FixedSizeBinaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*FixedSizeBinaryBuilder) UnsafeAppend(v []byte)
(*FixedSizeBinaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*FixedSizeBinaryBuilder : Builder
*FixedSizeBinaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*FixedSizeBinaryBuilder : github.com/goccy/go-json.Unmarshaler
*FixedSizeBinaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*FixedSizeBinaryBuilder : encoding/json.Unmarshaler
func NewFixedSizeBinaryBuilder(mem memory.Allocator, dtype *arrow.FixedSizeBinaryType) *FixedSizeBinaryBuilder
(*FixedSizeBinaryDictionaryBuilder) Append(v []byte) error
(*FixedSizeBinaryDictionaryBuilder) AppendArray(arr arrow.Array) error
(*FixedSizeBinaryDictionaryBuilder) AppendEmptyValue()
(*FixedSizeBinaryDictionaryBuilder) AppendEmptyValues(n int)
(*FixedSizeBinaryDictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*FixedSizeBinaryDictionaryBuilder) AppendNull()
(*FixedSizeBinaryDictionaryBuilder) AppendNulls(n int)
(*FixedSizeBinaryDictionaryBuilder) AppendValueFromString(s string) error
(*FixedSizeBinaryDictionaryBuilder) Cap() int
(*FixedSizeBinaryDictionaryBuilder) DictionarySize() int
(*FixedSizeBinaryDictionaryBuilder) IndexBuilder() IndexBuilder
(*FixedSizeBinaryDictionaryBuilder) InsertDictValues(arr *FixedSizeBinary) (err error)
(*FixedSizeBinaryDictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*FixedSizeBinaryDictionaryBuilder) NewArray() arrow.Array
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)
(*FixedSizeBinaryDictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*FixedSizeBinaryDictionaryBuilder) Release()
(*FixedSizeBinaryDictionaryBuilder) Reserve(n int)
(*FixedSizeBinaryDictionaryBuilder) ResetFull()
(*FixedSizeBinaryDictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*FixedSizeBinaryDictionaryBuilder) SetNull(i int)
(*FixedSizeBinaryDictionaryBuilder) Type() arrow.DataType
(*FixedSizeBinaryDictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*FixedSizeBinaryDictionaryBuilder) UnmarshalJSON(data []byte) error
(*FixedSizeBinaryDictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*FixedSizeBinaryDictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*FixedSizeBinaryDictionaryBuilder : Builder
*FixedSizeBinaryDictionaryBuilder : DictionaryBuilder
*FixedSizeBinaryDictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*FixedSizeBinaryDictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*FixedSizeBinaryDictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*FixedSizeBinaryDictionaryBuilder : encoding/json.Unmarshaler
FixedSizeList represents an immutable sequence of N array values.
(*FixedSizeList) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*FixedSizeList) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*FixedSizeList) ListValues() arrow.Array
(*FixedSizeList) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*FixedSizeList) Offset() int
(*FixedSizeList) Release()
(*FixedSizeList) Retain()
(*FixedSizeList) String() string
(*FixedSizeList) ValueOffsets(i int) (start, end int64)
(*FixedSizeList) ValueStr(i int) string
*FixedSizeList : ListLike
*FixedSizeList : VarLenListLike
*FixedSizeList : github.com/apache/arrow-go/v18/arrow.Array[T]
*FixedSizeList : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*FixedSizeList : github.com/goccy/go-json.Marshaler
*FixedSizeList : encoding/json.Marshaler
*FixedSizeList : expvar.Var
*FixedSizeList : fmt.Stringer
func NewFixedSizeListData(data arrow.ArrayData) *FixedSizeList
func (*FixedSizeListBuilder).NewListArray() (a *FixedSizeList)
(*FixedSizeListBuilder) Append(v bool)
(*FixedSizeListBuilder) AppendEmptyValue()
(*FixedSizeListBuilder) AppendEmptyValues(n int)
AppendNull will append null values to the underlying values by itself
AppendNulls will append n null values to the underlying values by itself
(*FixedSizeListBuilder) AppendValueFromString(s string) error
(*FixedSizeListBuilder) AppendValues(valid []bool)
(*FixedSizeListBuilder) AppendWithSize(v bool, _ int)
Cap returns the total number of elements that can be stored without allocating additional memory.
(*FixedSizeListBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*FixedSizeListBuilder) SetNull(i int)
(*FixedSizeListBuilder) Type() arrow.DataType
(*FixedSizeListBuilder) Unmarshal(dec *json.Decoder) error
(*FixedSizeListBuilder) UnmarshalJSON(data []byte) error
(*FixedSizeListBuilder) UnmarshalOne(dec *json.Decoder) error
(*FixedSizeListBuilder) UnsafeAppendBoolToBitmap(isValid bool)
(*FixedSizeListBuilder) ValueBuilder() Builder
*FixedSizeListBuilder : Builder
*FixedSizeListBuilder : ListLikeBuilder
*FixedSizeListBuilder : VarLenListLikeBuilder
*FixedSizeListBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*FixedSizeListBuilder : github.com/goccy/go-json.Unmarshaler
*FixedSizeListBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*FixedSizeListBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ListLikeBuilder
*FixedSizeListBuilder : encoding/json.Unmarshaler
func NewFixedSizeListBuilder(mem memory.Allocator, n int32, etype arrow.DataType) *FixedSizeListBuilder
func NewFixedSizeListBuilderWithField(mem memory.Allocator, n int32, field arrow.Field) *FixedSizeListBuilder
A type which represents an immutable sequence of Float16 values.
(*Float16) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Float16) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Float16) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Float16) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Float16) String() string
(*Float16) Value(i int) float16.Num
(*Float16) ValueStr(i int) string
(*Float16) Values() []float16.Num
*Float16 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Float16 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Float16 : github.com/goccy/go-json.Marshaler
*Float16 : encoding/json.Marshaler
*Float16 : expvar.Var
*Float16 : fmt.Stringer
func NewFloat16Data(data arrow.ArrayData) *Float16
func (*Float16Builder).NewFloat16Array() (a *Float16)
(*Float16Builder) Append(v float16.Num)
(*Float16Builder) AppendEmptyValue()
(*Float16Builder) AppendEmptyValues(n int)
(*Float16Builder) AppendNull()
(*Float16Builder) AppendNulls(n int)
(*Float16Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Float16Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Float16Builder) SetNull(i int)
(*Float16Builder) Type() arrow.DataType
(*Float16Builder) Unmarshal(dec *json.Decoder) 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.
(*Float16Builder) UnmarshalOne(dec *json.Decoder) error
(*Float16Builder) UnsafeAppend(v float16.Num)
(*Float16Builder) UnsafeAppendBoolToBitmap(isValid bool)
*Float16Builder : Builder
*Float16Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Float16Builder : github.com/goccy/go-json.Unmarshaler
*Float16Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Float16Builder : encoding/json.Unmarshaler
func NewFloat16Builder(mem memory.Allocator) *Float16Builder
(*Float16DictionaryBuilder) Append(v float16.Num) error
(*Float16DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Float16DictionaryBuilder) AppendEmptyValue()
(*Float16DictionaryBuilder) AppendEmptyValues(n int)
(*Float16DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Float16DictionaryBuilder) AppendNull()
(*Float16DictionaryBuilder) AppendNulls(n int)
(*Float16DictionaryBuilder) AppendValueFromString(s string) error
(*Float16DictionaryBuilder) Cap() int
(*Float16DictionaryBuilder) DictionarySize() int
(*Float16DictionaryBuilder) IndexBuilder() IndexBuilder
(*Float16DictionaryBuilder) InsertDictValues(arr arrValues[float16.Num]) (err error)
(*Float16DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Float16DictionaryBuilder) NewArray() arrow.Array
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)
(*Float16DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Float16DictionaryBuilder) Release()
(*Float16DictionaryBuilder) Reserve(n int)
(*Float16DictionaryBuilder) ResetFull()
(*Float16DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Float16DictionaryBuilder) SetNull(i int)
(*Float16DictionaryBuilder) Type() arrow.DataType
(*Float16DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Float16DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Float16DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Float16DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Float16DictionaryBuilder : Builder
*Float16DictionaryBuilder : DictionaryBuilder
*Float16DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Float16DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Float16DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Float16DictionaryBuilder : encoding/json.Unmarshaler
(*Float32) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Float32) Float32Values() []float32
(*Float32) GetOneForMarshal(i int) any
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Float32) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Float32) Offset() int
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.
(*Float32) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Float32) String() string
(*Float32) Value(i int) float32
(*Float32) ValueStr(i int) string
(*Float32) Values() []float32
*Float32 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Float32 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Float32 : github.com/goccy/go-json.Marshaler
*Float32 : encoding/json.Marshaler
*Float32 : expvar.Var
*Float32 : fmt.Stringer
func NewFloat32Data(data arrow.ArrayData) *Float32
func (*Float32Builder).NewFloat32Array() (a *Float32)
(*Float32Builder) Append(v float32)
(*Float32Builder) AppendEmptyValue()
(*Float32Builder) AppendEmptyValues(n int)
(*Float32Builder) AppendNull()
(*Float32Builder) AppendNulls(n int)
(*Float32Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Float32Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Float32Builder) SetNull(i int)
(*Float32Builder) Type() arrow.DataType
(*Float32Builder) Unmarshal(dec *json.Decoder) error
(*Float32Builder) UnmarshalJSON(data []byte) error
(*Float32Builder) UnmarshalOne(dec *json.Decoder) error
(*Float32Builder) UnsafeAppend(v float32)
(*Float32Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Float32Builder) Value(i int) float32
*Float32Builder : Builder
*Float32Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Float32Builder : github.com/goccy/go-json.Unmarshaler
*Float32Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Float32Builder : encoding/json.Unmarshaler
func NewFloat32Builder(mem memory.Allocator) *Float32Builder
(*Float32DictionaryBuilder) Append(v float32) error
(*Float32DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Float32DictionaryBuilder) AppendEmptyValue()
(*Float32DictionaryBuilder) AppendEmptyValues(n int)
(*Float32DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Float32DictionaryBuilder) AppendNull()
(*Float32DictionaryBuilder) AppendNulls(n int)
(*Float32DictionaryBuilder) AppendValueFromString(s string) error
(*Float32DictionaryBuilder) Cap() int
(*Float32DictionaryBuilder) DictionarySize() int
(*Float32DictionaryBuilder) IndexBuilder() IndexBuilder
(*Float32DictionaryBuilder) InsertDictValues(arr arrValues[float32]) (err error)
(*Float32DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Float32DictionaryBuilder) NewArray() arrow.Array
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)
(*Float32DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Float32DictionaryBuilder) Release()
(*Float32DictionaryBuilder) Reserve(n int)
(*Float32DictionaryBuilder) ResetFull()
(*Float32DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Float32DictionaryBuilder) SetNull(i int)
(*Float32DictionaryBuilder) Type() arrow.DataType
(*Float32DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Float32DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Float32DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Float32DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Float32DictionaryBuilder : Builder
*Float32DictionaryBuilder : DictionaryBuilder
*Float32DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Float32DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Float32DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Float32DictionaryBuilder : encoding/json.Unmarshaler
(*Float64) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Float64) Float64Values() []float64
(*Float64) GetOneForMarshal(i int) any
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Float64) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Float64) Offset() int
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.
(*Float64) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Float64) String() string
(*Float64) Value(i int) float64
(*Float64) ValueStr(i int) string
(*Float64) Values() []float64
*Float64 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Float64 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Float64 : github.com/goccy/go-json.Marshaler
*Float64 : encoding/json.Marshaler
*Float64 : expvar.Var
*Float64 : fmt.Stringer
func NewFloat64Data(data arrow.ArrayData) *Float64
func (*Float64Builder).NewFloat64Array() (a *Float64)
func github.com/polarsignals/frostdb/query/physicalplan.AddFloat64s(mem memory.Allocator, left, right *Float64) *Float64
func github.com/polarsignals/frostdb/query/physicalplan.DivFloat64s(mem memory.Allocator, left, right *Float64) *Float64
func github.com/polarsignals/frostdb/query/physicalplan.MulFloat64s(mem memory.Allocator, left, right *Float64) *Float64
func github.com/polarsignals/frostdb/query/physicalplan.SubFloat64s(mem memory.Allocator, left, right *Float64) *Float64
func github.com/apache/arrow-go/v18/arrow/math.Float64Funcs.Sum(a *Float64) float64
func github.com/polarsignals/frostdb/query/physicalplan.AddFloat64s(mem memory.Allocator, left, right *Float64) *Float64
func github.com/polarsignals/frostdb/query/physicalplan.DivFloat64s(mem memory.Allocator, left, right *Float64) *Float64
func github.com/polarsignals/frostdb/query/physicalplan.MulFloat64s(mem memory.Allocator, left, right *Float64) *Float64
func github.com/polarsignals/frostdb/query/physicalplan.SubFloat64s(mem memory.Allocator, left, right *Float64) *Float64
(*Float64Builder) Append(v float64)
(*Float64Builder) AppendEmptyValue()
(*Float64Builder) AppendEmptyValues(n int)
(*Float64Builder) AppendNull()
(*Float64Builder) AppendNulls(n int)
(*Float64Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Float64Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Float64Builder) SetNull(i int)
(*Float64Builder) Type() arrow.DataType
(*Float64Builder) Unmarshal(dec *json.Decoder) error
(*Float64Builder) UnmarshalJSON(data []byte) error
(*Float64Builder) UnmarshalOne(dec *json.Decoder) error
(*Float64Builder) UnsafeAppend(v float64)
(*Float64Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Float64Builder) Value(i int) float64
*Float64Builder : Builder
*Float64Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Float64Builder : github.com/goccy/go-json.Unmarshaler
*Float64Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Float64Builder : encoding/json.Unmarshaler
func NewFloat64Builder(mem memory.Allocator) *Float64Builder
(*Float64DictionaryBuilder) Append(v float64) error
(*Float64DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Float64DictionaryBuilder) AppendEmptyValue()
(*Float64DictionaryBuilder) AppendEmptyValues(n int)
(*Float64DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Float64DictionaryBuilder) AppendNull()
(*Float64DictionaryBuilder) AppendNulls(n int)
(*Float64DictionaryBuilder) AppendValueFromString(s string) error
(*Float64DictionaryBuilder) Cap() int
(*Float64DictionaryBuilder) DictionarySize() int
(*Float64DictionaryBuilder) IndexBuilder() IndexBuilder
(*Float64DictionaryBuilder) InsertDictValues(arr arrValues[float64]) (err error)
(*Float64DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Float64DictionaryBuilder) NewArray() arrow.Array
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)
(*Float64DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Float64DictionaryBuilder) Release()
(*Float64DictionaryBuilder) Reserve(n int)
(*Float64DictionaryBuilder) ResetFull()
(*Float64DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Float64DictionaryBuilder) SetNull(i int)
(*Float64DictionaryBuilder) Type() arrow.DataType
(*Float64DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Float64DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Float64DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Float64DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Float64DictionaryBuilder : Builder
*Float64DictionaryBuilder : DictionaryBuilder
*Float64DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Float64DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Float64DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Float64DictionaryBuilder : encoding/json.Unmarshaler
func WithMultipleDocs() FromJSONOption
func WithStartOffset(off int64) FromJSONOption
func WithUseNumber() FromJSONOption
func ChunkedFromJSON(mem memory.Allocator, dt arrow.DataType, chunkStrs []string, opts ...FromJSONOption) (*arrow.Chunked, error)
func FromJSON(mem memory.Allocator, dt arrow.DataType, r io.Reader, opts ...FromJSONOption) (arr arrow.Array, offset int64, err error)
func RecordFromJSON(mem memory.Allocator, schema *arrow.Schema, r io.Reader, opts ...FromJSONOption) (arrow.RecordBatch, int64, error)
func TableFromJSON(mem memory.Allocator, sc *arrow.Schema, recJSON []string, opt ...FromJSONOption) (arrow.Table, error)
helper for building the properly typed indices of the dictionary builder
Append func(int)
Builder Builder
AppendEmptyValue adds a new zero value of the appropriate type
AppendEmptyValues adds new n zero values of the appropriate type
AppendNull adds a new null value to the array being built.
AppendNulls adds new n null values to the array being built.
AppendValueFromString adds a new value from a string. Inverse of array.ValueStr(i int) string
Cap returns the total number of elements that can be stored
without allocating additional memory.
IsNull returns if a previously appended value at a given index is null or not.
Len returns the number of elements in the array builder.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
SetNull sets the value at index i to null.
Type returns the datatype that this is building
( IndexBuilder) Unmarshal(*json.Decoder) error
( IndexBuilder) UnmarshalJSON([]byte) error
( IndexBuilder) UnmarshalOne(*json.Decoder) error
( IndexBuilder) UnsafeAppendBoolToBitmap(bool)
IndexBuilder : Builder
IndexBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
IndexBuilder : github.com/goccy/go-json.Unmarshaler
IndexBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
IndexBuilder : encoding/json.Unmarshaler
(*Int16) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Int16) GetOneForMarshal(i int) any
(*Int16) Int16Values() []int16
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Int16) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Int16) Offset() int
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.
(*Int16) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Int16) String() string
(*Int16) Value(i int) int16
(*Int16) ValueStr(i int) string
(*Int16) Values() []int16
*Int16 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Int16 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Int16 : github.com/goccy/go-json.Marshaler
*Int16 : encoding/json.Marshaler
*Int16 : expvar.Var
*Int16 : fmt.Stringer
func NewInt16Data(data arrow.ArrayData) *Int16
func (*Int16Builder).NewInt16Array() (a *Int16)
(*Int16Builder) Append(v int16)
(*Int16Builder) AppendEmptyValue()
(*Int16Builder) AppendEmptyValues(n int)
(*Int16Builder) AppendNull()
(*Int16Builder) AppendNulls(n int)
(*Int16Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Int16Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Int16Builder) SetNull(i int)
(*Int16Builder) Type() arrow.DataType
(*Int16Builder) Unmarshal(dec *json.Decoder) error
(*Int16Builder) UnmarshalJSON(data []byte) error
(*Int16Builder) UnmarshalOne(dec *json.Decoder) error
(*Int16Builder) UnsafeAppend(v int16)
(*Int16Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Int16Builder) Value(i int) int16
*Int16Builder : Builder
*Int16Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Int16Builder : github.com/goccy/go-json.Unmarshaler
*Int16Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Int16Builder : encoding/json.Unmarshaler
func NewInt16Builder(mem memory.Allocator) *Int16Builder
(*Int16DictionaryBuilder) Append(v int16) error
(*Int16DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Int16DictionaryBuilder) AppendEmptyValue()
(*Int16DictionaryBuilder) AppendEmptyValues(n int)
(*Int16DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Int16DictionaryBuilder) AppendNull()
(*Int16DictionaryBuilder) AppendNulls(n int)
(*Int16DictionaryBuilder) AppendValueFromString(s string) error
(*Int16DictionaryBuilder) Cap() int
(*Int16DictionaryBuilder) DictionarySize() int
(*Int16DictionaryBuilder) IndexBuilder() IndexBuilder
(*Int16DictionaryBuilder) InsertDictValues(arr arrValues[int16]) (err error)
(*Int16DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Int16DictionaryBuilder) NewArray() arrow.Array
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)
(*Int16DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Int16DictionaryBuilder) Release()
(*Int16DictionaryBuilder) Reserve(n int)
(*Int16DictionaryBuilder) ResetFull()
(*Int16DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Int16DictionaryBuilder) SetNull(i int)
(*Int16DictionaryBuilder) Type() arrow.DataType
(*Int16DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Int16DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Int16DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Int16DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Int16DictionaryBuilder : Builder
*Int16DictionaryBuilder : DictionaryBuilder
*Int16DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Int16DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Int16DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Int16DictionaryBuilder : encoding/json.Unmarshaler
(*Int32) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Int32) GetOneForMarshal(i int) any
(*Int32) Int32Values() []int32
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Int32) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Int32) Offset() int
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.
(*Int32) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Int32) String() string
(*Int32) Value(i int) int32
(*Int32) ValueStr(i int) string
(*Int32) Values() []int32
*Int32 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Int32 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Int32 : github.com/goccy/go-json.Marshaler
*Int32 : encoding/json.Marshaler
*Int32 : expvar.Var
*Int32 : fmt.Stringer
func NewInt32Data(data arrow.ArrayData) *Int32
func (*Int32Builder).NewInt32Array() (a *Int32)
func github.com/polarsignals/frostdb/pqarrow/arrowutils.SortRecord(r arrow.Record, columns []arrowutils.SortingColumn) (*Int32, error)
func github.com/polarsignals/frostdb/query/physicalplan.AddInt32s(mem memory.Allocator, left, right *Int32) *Int32
func github.com/polarsignals/frostdb/query/physicalplan.DivInt32s(mem memory.Allocator, left, right *Int32) *Int32
func github.com/polarsignals/frostdb/query/physicalplan.MulInt32s(mem memory.Allocator, left, right *Int32) *Int32
func github.com/polarsignals/frostdb/query/physicalplan.SubInt32s(mem memory.Allocator, left, right *Int32) *Int32
func github.com/polarsignals/frostdb/pqarrow/arrowutils.Take(ctx context.Context, r arrow.Record, indices *Int32) (arrow.Record, error)
func github.com/polarsignals/frostdb/pqarrow/arrowutils.TakeColumn(ctx context.Context, a arrow.Array, idx int, arr []arrow.Array, indices *Int32) error
func github.com/polarsignals/frostdb/pqarrow/arrowutils.TakeDictColumn(ctx context.Context, a *Dictionary, idx int, arr []arrow.Array, indices *Int32) error
func github.com/polarsignals/frostdb/pqarrow/arrowutils.TakeListColumn(ctx context.Context, a *List, idx int, arr []arrow.Array, indices *Int32) error
func github.com/polarsignals/frostdb/pqarrow/arrowutils.TakeRunEndEncodedColumn(ctx context.Context, a *RunEndEncoded, idx int, arr []arrow.Array, indices *Int32) error
func github.com/polarsignals/frostdb/pqarrow/arrowutils.TakeStructColumn(ctx context.Context, a *Struct, idx int, arr []arrow.Array, indices *Int32) error
func github.com/polarsignals/frostdb/query/physicalplan.AddInt32s(mem memory.Allocator, left, right *Int32) *Int32
func github.com/polarsignals/frostdb/query/physicalplan.DivInt32s(mem memory.Allocator, left, right *Int32) *Int32
func github.com/polarsignals/frostdb/query/physicalplan.MulInt32s(mem memory.Allocator, left, right *Int32) *Int32
func github.com/polarsignals/frostdb/query/physicalplan.SubInt32s(mem memory.Allocator, left, right *Int32) *Int32
(*Int32Builder) Append(v int32)
(*Int32Builder) AppendEmptyValue()
(*Int32Builder) AppendEmptyValues(n int)
(*Int32Builder) AppendNull()
(*Int32Builder) AppendNulls(n int)
(*Int32Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Int32Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Int32Builder) SetNull(i int)
(*Int32Builder) Type() arrow.DataType
(*Int32Builder) Unmarshal(dec *json.Decoder) error
(*Int32Builder) UnmarshalJSON(data []byte) error
(*Int32Builder) UnmarshalOne(dec *json.Decoder) error
(*Int32Builder) UnsafeAppend(v int32)
(*Int32Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Int32Builder) Value(i int) int32
*Int32Builder : Builder
*Int32Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Int32Builder : github.com/goccy/go-json.Unmarshaler
*Int32Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Int32Builder : encoding/json.Unmarshaler
func NewInt32Builder(mem memory.Allocator) *Int32Builder
(*Int32DictionaryBuilder) Append(v int32) error
(*Int32DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Int32DictionaryBuilder) AppendEmptyValue()
(*Int32DictionaryBuilder) AppendEmptyValues(n int)
(*Int32DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Int32DictionaryBuilder) AppendNull()
(*Int32DictionaryBuilder) AppendNulls(n int)
(*Int32DictionaryBuilder) AppendValueFromString(s string) error
(*Int32DictionaryBuilder) Cap() int
(*Int32DictionaryBuilder) DictionarySize() int
(*Int32DictionaryBuilder) IndexBuilder() IndexBuilder
(*Int32DictionaryBuilder) InsertDictValues(arr arrValues[int32]) (err error)
(*Int32DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Int32DictionaryBuilder) NewArray() arrow.Array
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)
(*Int32DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Int32DictionaryBuilder) Release()
(*Int32DictionaryBuilder) Reserve(n int)
(*Int32DictionaryBuilder) ResetFull()
(*Int32DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Int32DictionaryBuilder) SetNull(i int)
(*Int32DictionaryBuilder) Type() arrow.DataType
(*Int32DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Int32DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Int32DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Int32DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Int32DictionaryBuilder : Builder
*Int32DictionaryBuilder : DictionaryBuilder
*Int32DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Int32DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Int32DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Int32DictionaryBuilder : encoding/json.Unmarshaler
(*Int64) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Int64) GetOneForMarshal(i int) any
(*Int64) Int64Values() []int64
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Int64) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Int64) Offset() int
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.
(*Int64) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Int64) String() string
(*Int64) Value(i int) int64
(*Int64) ValueStr(i int) string
(*Int64) Values() []int64
*Int64 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Int64 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Int64 : github.com/goccy/go-json.Marshaler
*Int64 : encoding/json.Marshaler
*Int64 : expvar.Var
*Int64 : fmt.Stringer
func NewInt64Data(data arrow.ArrayData) *Int64
func (*Int64Builder).NewInt64Array() (a *Int64)
func github.com/polarsignals/frostdb/query/physicalplan.AddInt64s(mem memory.Allocator, left, right *Int64) *Int64
func github.com/polarsignals/frostdb/query/physicalplan.DivInt64s(mem memory.Allocator, left, right *Int64) *Int64
func github.com/polarsignals/frostdb/query/physicalplan.MulInt64s(mem memory.Allocator, left, right *Int64) *Int64
func github.com/polarsignals/frostdb/query/physicalplan.SubInt64s(mem memory.Allocator, left, right *Int64) *Int64
func github.com/apache/arrow-go/v18/arrow/math.Int64Funcs.Sum(a *Int64) int64
func github.com/polarsignals/frostdb/query/physicalplan.AddInt64s(mem memory.Allocator, left, right *Int64) *Int64
func github.com/polarsignals/frostdb/query/physicalplan.DivInt64s(mem memory.Allocator, left, right *Int64) *Int64
func github.com/polarsignals/frostdb/query/physicalplan.MulInt64s(mem memory.Allocator, left, right *Int64) *Int64
func github.com/polarsignals/frostdb/query/physicalplan.SubInt64s(mem memory.Allocator, left, right *Int64) *Int64
(*Int64Builder) Append(v int64)
(*Int64Builder) AppendEmptyValue()
(*Int64Builder) AppendEmptyValues(n int)
(*Int64Builder) AppendNull()
(*Int64Builder) AppendNulls(n int)
(*Int64Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Int64Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Int64Builder) SetNull(i int)
(*Int64Builder) Type() arrow.DataType
(*Int64Builder) Unmarshal(dec *json.Decoder) error
(*Int64Builder) UnmarshalJSON(data []byte) error
(*Int64Builder) UnmarshalOne(dec *json.Decoder) error
(*Int64Builder) UnsafeAppend(v int64)
(*Int64Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Int64Builder) Value(i int) int64
*Int64Builder : Builder
*Int64Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Int64Builder : github.com/goccy/go-json.Unmarshaler
*Int64Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Int64Builder : encoding/json.Unmarshaler
func NewInt64Builder(mem memory.Allocator) *Int64Builder
(*Int64DictionaryBuilder) Append(v int64) error
(*Int64DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Int64DictionaryBuilder) AppendEmptyValue()
(*Int64DictionaryBuilder) AppendEmptyValues(n int)
(*Int64DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Int64DictionaryBuilder) AppendNull()
(*Int64DictionaryBuilder) AppendNulls(n int)
(*Int64DictionaryBuilder) AppendValueFromString(s string) error
(*Int64DictionaryBuilder) Cap() int
(*Int64DictionaryBuilder) DictionarySize() int
(*Int64DictionaryBuilder) IndexBuilder() IndexBuilder
(*Int64DictionaryBuilder) InsertDictValues(arr arrValues[int64]) (err error)
(*Int64DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Int64DictionaryBuilder) NewArray() arrow.Array
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)
(*Int64DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Int64DictionaryBuilder) Release()
(*Int64DictionaryBuilder) Reserve(n int)
(*Int64DictionaryBuilder) ResetFull()
(*Int64DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Int64DictionaryBuilder) SetNull(i int)
(*Int64DictionaryBuilder) Type() arrow.DataType
(*Int64DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Int64DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Int64DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Int64DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Int64DictionaryBuilder : Builder
*Int64DictionaryBuilder : DictionaryBuilder
*Int64DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Int64DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Int64DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Int64DictionaryBuilder : encoding/json.Unmarshaler
(*Int8) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Int8) GetOneForMarshal(i int) any
(*Int8) Int8Values() []int8
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Int8) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Int8) Offset() int
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.
(*Int8) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Int8) String() string
(*Int8) Value(i int) int8
(*Int8) ValueStr(i int) string
(*Int8) Values() []int8
*Int8 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Int8 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Int8 : github.com/goccy/go-json.Marshaler
*Int8 : encoding/json.Marshaler
*Int8 : expvar.Var
*Int8 : fmt.Stringer
func NewInt8Data(data arrow.ArrayData) *Int8
func (*Int8Builder).NewInt8Array() (a *Int8)
(*Int8Builder) Append(v int8)
(*Int8Builder) AppendEmptyValue()
(*Int8Builder) AppendEmptyValues(n int)
(*Int8Builder) AppendNull()
(*Int8Builder) AppendNulls(n int)
(*Int8Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Int8Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Int8Builder) SetNull(i int)
(*Int8Builder) Type() arrow.DataType
(*Int8Builder) Unmarshal(dec *json.Decoder) error
(*Int8Builder) UnmarshalJSON(data []byte) error
(*Int8Builder) UnmarshalOne(dec *json.Decoder) error
(*Int8Builder) UnsafeAppend(v int8)
(*Int8Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Int8Builder) Value(i int) int8
*Int8Builder : Builder
*Int8Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Int8Builder : github.com/goccy/go-json.Unmarshaler
*Int8Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Int8Builder : encoding/json.Unmarshaler
func NewInt8Builder(mem memory.Allocator) *Int8Builder
(*Int8DictionaryBuilder) Append(v int8) error
(*Int8DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Int8DictionaryBuilder) AppendEmptyValue()
(*Int8DictionaryBuilder) AppendEmptyValues(n int)
(*Int8DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Int8DictionaryBuilder) AppendNull()
(*Int8DictionaryBuilder) AppendNulls(n int)
(*Int8DictionaryBuilder) AppendValueFromString(s string) error
(*Int8DictionaryBuilder) Cap() int
(*Int8DictionaryBuilder) DictionarySize() int
(*Int8DictionaryBuilder) IndexBuilder() IndexBuilder
(*Int8DictionaryBuilder) InsertDictValues(arr arrValues[int8]) (err error)
(*Int8DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Int8DictionaryBuilder) NewArray() arrow.Array
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)
(*Int8DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Int8DictionaryBuilder) Release()
(*Int8DictionaryBuilder) Reserve(n int)
(*Int8DictionaryBuilder) ResetFull()
(*Int8DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Int8DictionaryBuilder) SetNull(i int)
(*Int8DictionaryBuilder) Type() arrow.DataType
(*Int8DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Int8DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Int8DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Int8DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Int8DictionaryBuilder : Builder
*Int8DictionaryBuilder : DictionaryBuilder
*Int8DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Int8DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Int8DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Int8DictionaryBuilder : encoding/json.Unmarshaler
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.
Err returns the last encountered error
Next returns true if it read in a record, which will be available via RecordBatch
and false if there is either an error or the end of the reader.
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.
Deprecated: Use [RecordBatch] instead.
RecordBatch returns the last read in record batch. The returned record batch is only valid
until the next call to Next unless Retain is called on the record batch itself.
(*JSONReader) Release()
(*JSONReader) Retain()
(*JSONReader) Schema() *arrow.Schema
*JSONReader : RecordReader
*JSONReader : github.com/apache/arrow-go/v18/arrow/compute/exec.ArrayIter[bool]
*JSONReader : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
func NewJSONReader(r io.Reader, schema *arrow.Schema, opts ...Option) *JSONReader
(*LargeBinary) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*LargeBinary) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*LargeBinary) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*LargeBinary) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*LargeBinary) String() string
(*LargeBinary) Value(i int) []byte
(*LargeBinary) ValueBytes() []byte
(*LargeBinary) ValueLen(i int) int
(*LargeBinary) ValueOffset(i int) int64
(*LargeBinary) ValueOffset64(i int) int64
(*LargeBinary) ValueOffsets() []int64
(*LargeBinary) ValueStr(i int) string
(*LargeBinary) ValueString(i int) string
*LargeBinary : BinaryLike
*LargeBinary : github.com/apache/arrow-go/v18/arrow.Array[T]
*LargeBinary : github.com/apache/arrow-go/v18/arrow.TypedArray[[]byte]
*LargeBinary : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*LargeBinary : github.com/goccy/go-json.Marshaler
*LargeBinary : encoding/json.Marshaler
*LargeBinary : expvar.Var
*LargeBinary : fmt.Stringer
func NewLargeBinaryData(data arrow.ArrayData) *LargeBinary
func (*BinaryBuilder).NewLargeBinaryArray() (a *LargeBinary)
LargeList represents an immutable sequence of array values.
(*LargeList) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*LargeList) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*LargeList) ListValues() arrow.Array
(*LargeList) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*LargeList) Offset() int
(*LargeList) Offsets() []int64
(*LargeList) Release()
(*LargeList) Retain()
(*LargeList) String() string
(*LargeList) ValueOffsets(i int) (start, end int64)
(*LargeList) ValueStr(i int) string
*LargeList : ListLike
*LargeList : VarLenListLike
*LargeList : github.com/apache/arrow-go/v18/arrow.Array[T]
*LargeList : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*LargeList : github.com/goccy/go-json.Marshaler
*LargeList : encoding/json.Marshaler
*LargeList : expvar.Var
*LargeList : fmt.Stringer
func NewLargeListData(data arrow.ArrayData) *LargeList
func (*LargeListBuilder).NewLargeListArray() (a *LargeList)
(*LargeListBuilder) Append(v bool)
(*LargeListBuilder) AppendEmptyValue()
(*LargeListBuilder) AppendEmptyValues(n int)
(*LargeListBuilder) AppendNull()
(*LargeListBuilder) AppendNulls(n int)
(*LargeListBuilder) AppendValueFromString(s string) error
(*LargeListBuilder) AppendValues(offsets []int64, valid []bool)
(*LargeListBuilder) AppendWithSize(v bool, _ int)
Cap returns the total number of elements that can be stored without allocating additional memory.
(*LargeListBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
NewArray creates a LargeList array from the memory buffers used by the builder and resets the LargeListBuilder
so it can be used to build a new array.
NewLargeListArray creates a List array from the memory buffers used by the builder and resets the LargeListBuilder
so it can be used to build a new array.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*LargeListBuilder) SetNull(i int)
(*LargeListBuilder) Type() arrow.DataType
(*LargeListBuilder) Unmarshal(dec *json.Decoder) error
(*LargeListBuilder) UnmarshalJSON(data []byte) error
(*LargeListBuilder) UnmarshalOne(dec *json.Decoder) error
(*LargeListBuilder) UnsafeAppendBoolToBitmap(isValid bool)
(*LargeListBuilder) ValueBuilder() Builder
*LargeListBuilder : Builder
*LargeListBuilder : ListLikeBuilder
*LargeListBuilder : VarLenListLikeBuilder
*LargeListBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*LargeListBuilder : github.com/goccy/go-json.Unmarshaler
*LargeListBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*LargeListBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ListLikeBuilder
*LargeListBuilder : encoding/json.Unmarshaler
func NewLargeListBuilder(mem memory.Allocator, etype arrow.DataType) *LargeListBuilder
func NewLargeListBuilderWithField(mem memory.Allocator, field arrow.Field) *LargeListBuilder
LargeListView represents an immutable sequence of array values defined by an
offset into a child array and a length.
(*LargeListView) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*LargeListView) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*LargeListView) ListValues() arrow.Array
(*LargeListView) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*LargeListView) Offset() int
(*LargeListView) Offsets() []int64
(*LargeListView) Release()
(*LargeListView) Retain()
(*LargeListView) Sizes() []int64
(*LargeListView) String() string
(*LargeListView) Validate() error
(*LargeListView) ValidateFull() error
(*LargeListView) ValueOffsets(i int) (start, end int64)
(*LargeListView) ValueStr(i int) string
*LargeListView : ListLike
*LargeListView : VarLenListLike
*LargeListView : github.com/apache/arrow-go/v18/arrow.Array[T]
*LargeListView : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*LargeListView : github.com/goccy/go-json.Marshaler
*LargeListView : encoding/json.Marshaler
*LargeListView : expvar.Var
*LargeListView : fmt.Stringer
func NewLargeListViewData(data arrow.ArrayData) *LargeListView
func (*LargeListViewBuilder).NewLargeListViewArray() (a *LargeListView)
(*LargeListViewBuilder) Append(v bool)
(*LargeListViewBuilder) AppendDimensions(offset int, listSize int)
(*LargeListViewBuilder) AppendEmptyValue()
(*LargeListViewBuilder) AppendEmptyValues(n int)
(*LargeListViewBuilder) AppendNull()
(*LargeListViewBuilder) AppendNulls(n int)
(*LargeListViewBuilder) AppendValueFromString(s string) error
(*LargeListViewBuilder) AppendValuesWithSizes(offsets []int64, sizes []int64, valid []bool)
(*LargeListViewBuilder) AppendWithSize(v bool, listSize int)
Cap returns the total number of elements that can be stored without allocating additional memory.
(*LargeListViewBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
NewArray creates a LargeListView array from the memory buffers used by the builder
and resets the LargeListViewBuilder so it can be used to build a new array.
NewLargeListViewArray creates a ListView array from the memory buffers used by the
builder and resets the LargeListViewBuilder so it can be used to build a new array.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*LargeListViewBuilder) SetNull(i int)
(*LargeListViewBuilder) Type() arrow.DataType
(*LargeListViewBuilder) Unmarshal(dec *json.Decoder) error
(*LargeListViewBuilder) UnmarshalJSON(data []byte) error
(*LargeListViewBuilder) UnmarshalOne(dec *json.Decoder) error
(*LargeListViewBuilder) UnsafeAppendBoolToBitmap(isValid bool)
(*LargeListViewBuilder) ValueBuilder() Builder
*LargeListViewBuilder : Builder
*LargeListViewBuilder : ListLikeBuilder
*LargeListViewBuilder : VarLenListLikeBuilder
*LargeListViewBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*LargeListViewBuilder : github.com/goccy/go-json.Unmarshaler
*LargeListViewBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*LargeListViewBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ListLikeBuilder
*LargeListViewBuilder : encoding/json.Unmarshaler
func NewLargeListViewBuilder(mem memory.Allocator, etype arrow.DataType) *LargeListViewBuilder
func NewLargeListViewBuilderWithField(mem memory.Allocator, field arrow.Field) *LargeListViewBuilder
String represents an immutable sequence of variable-length UTF-8 strings.
(*LargeString) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*LargeString) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*LargeString) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*LargeString) Offset() int
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.
Reset resets the String with a different set of Data.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*LargeString) String() string
Value returns the slice at index i. This value should not be mutated.
(*LargeString) ValueBytes() []byte
(*LargeString) ValueLen(i int) int
ValueOffset returns the offset of the value at index i.
(*LargeString) ValueOffset64(i int) int64
(*LargeString) ValueOffsets() []int64
(*LargeString) ValueStr(i int) string
*LargeString : BinaryLike
*LargeString : StringLike
*LargeString : github.com/apache/arrow-go/v18/arrow.Array[T]
*LargeString : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*LargeString : github.com/goccy/go-json.Marshaler
*LargeString : encoding/json.Marshaler
*LargeString : expvar.Var
*LargeString : fmt.Stringer
func NewLargeStringData(data arrow.ArrayData) *LargeString
func (*LargeStringBuilder).NewLargeStringArray() (a *LargeString)
A LargeStringBuilder is used to build a LargeString array using the Append methods.
LargeString is for when you need the offset buffer to be 64-bit integers
instead of 32-bit integers.
BinaryBuilder *BinaryBuilder
Append appends a string to the builder.
( LargeStringBuilder) AppendEmptyValue()
( LargeStringBuilder) AppendEmptyValues(n int)
( LargeStringBuilder) AppendNull()
( LargeStringBuilder) AppendNulls(n int)
( LargeStringBuilder) AppendString(v string)
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.
( LargeStringBuilder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
DataCap returns the total number of bytes that can be stored
without allocating additional memory.
DataLen returns the number of bytes in the data array.
( LargeStringBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
( LargeStringBuilder) NewLargeBinaryArray() (a *LargeBinary)
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.
NullN returns the number of null values in the array builder.
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.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
ReserveData ensures there is enough space for appending n bytes
by checking the capacity and resizing the data buffer if necessary.
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.
( LargeStringBuilder) ResizeData(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( LargeStringBuilder) SetNull(i int)
(*LargeStringBuilder) Type() arrow.DataType
(*LargeStringBuilder) Unmarshal(dec *json.Decoder) error
(*LargeStringBuilder) UnmarshalJSON(data []byte) error
(*LargeStringBuilder) UnmarshalOne(dec *json.Decoder) error
( LargeStringBuilder) UnsafeAppend(v []byte)
( LargeStringBuilder) UnsafeAppendBoolToBitmap(isValid bool)
Value returns the string at index i.
*LargeStringBuilder : Builder
*LargeStringBuilder : StringLikeBuilder
LargeStringBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*LargeStringBuilder : github.com/goccy/go-json.Unmarshaler
*LargeStringBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*LargeStringBuilder : encoding/json.Unmarshaler
func NewLargeStringBuilder(mem memory.Allocator) *LargeStringBuilder
List represents an immutable sequence of array values.
(*List) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*List) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*List) ListValues() arrow.Array
(*List) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*List) Offset() int
(*List) Offsets() []int32
(*List) Release()
(*List) Retain()
(*List) String() string
(*List) ValueOffsets(i int) (start, end int64)
(*List) ValueStr(i int) string
*List : ListLike
*List : VarLenListLike
*List : github.com/apache/arrow-go/v18/arrow.Array[T]
*List : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*List : github.com/goccy/go-json.Marshaler
*List : encoding/json.Marshaler
*List : expvar.Var
*List : fmt.Stringer
func NewListData(data arrow.ArrayData) *List
func (*ListBuilder).NewListArray() (a *List)
func github.com/polarsignals/frostdb/pqarrow/builder.(*ListBuilder).NewListArray() (a *List)
func github.com/polarsignals/frostdb/pqarrow/arrowutils.TakeListColumn(ctx context.Context, a *List, idx int, arr []arrow.Array, indices *Int32) error
(*ListBuilder) Append(v bool)
(*ListBuilder) AppendEmptyValue()
(*ListBuilder) AppendEmptyValues(n int)
(*ListBuilder) AppendNull()
(*ListBuilder) AppendNulls(n int)
(*ListBuilder) AppendValueFromString(s string) error
(*ListBuilder) AppendValues(offsets []int32, valid []bool)
(*ListBuilder) AppendWithSize(v bool, _ int)
Cap returns the total number of elements that can be stored without allocating additional memory.
(*ListBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*ListBuilder) SetNull(i int)
(*ListBuilder) Type() arrow.DataType
(*ListBuilder) Unmarshal(dec *json.Decoder) error
(*ListBuilder) UnmarshalJSON(data []byte) error
(*ListBuilder) UnmarshalOne(dec *json.Decoder) error
(*ListBuilder) UnsafeAppendBoolToBitmap(isValid bool)
(*ListBuilder) ValueBuilder() Builder
*ListBuilder : Builder
*ListBuilder : ListLikeBuilder
*ListBuilder : VarLenListLikeBuilder
*ListBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*ListBuilder : github.com/goccy/go-json.Unmarshaler
*ListBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*ListBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ListLikeBuilder
*ListBuilder : encoding/json.Unmarshaler
func NewListBuilder(mem memory.Allocator, etype arrow.DataType) *ListBuilder
func NewListBuilderWithField(mem memory.Allocator, field arrow.Field) *ListBuilder
( ListLike) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
Get single value to be marshalled with `json.Marshal`
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
( ListLike) ListValues() arrow.Array
( ListLike) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( ListLike) String() string
( ListLike) ValueOffsets(i int) (start, end int64)
ValueStr returns the value at index as a string.
*FixedSizeList
*LargeList
*LargeListView
*List
*ListView
*Map
VarLenListLike (interface)
ListLike : VarLenListLike
ListLike : github.com/apache/arrow-go/v18/arrow.Array[T]
ListLike : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
ListLike : github.com/goccy/go-json.Marshaler
ListLike : encoding/json.Marshaler
ListLike : expvar.Var
ListLike : fmt.Stringer
( ListLikeBuilder) Append(bool)
AppendEmptyValue adds a new zero value of the appropriate type
AppendEmptyValues adds new n zero values of the appropriate type
AppendNull adds a new null value to the array being built.
AppendNulls adds new n null values to the array being built.
AppendValueFromString adds a new value from a string. Inverse of array.ValueStr(i int) string
Cap returns the total number of elements that can be stored
without allocating additional memory.
IsNull returns if a previously appended value at a given index is null or not.
Len returns the number of elements in the array builder.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
SetNull sets the value at index i to null.
Type returns the datatype that this is building
( ListLikeBuilder) Unmarshal(*json.Decoder) error
( ListLikeBuilder) UnmarshalJSON([]byte) error
( ListLikeBuilder) UnmarshalOne(*json.Decoder) error
( ListLikeBuilder) UnsafeAppendBoolToBitmap(bool)
( ListLikeBuilder) ValueBuilder() Builder
*FixedSizeListBuilder
*LargeListBuilder
*LargeListViewBuilder
*ListBuilder
*ListViewBuilder
*MapBuilder
VarLenListLikeBuilder (interface)
ListLikeBuilder : Builder
ListLikeBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
ListLikeBuilder : github.com/goccy/go-json.Unmarshaler
ListLikeBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
ListLikeBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ListLikeBuilder
ListLikeBuilder : encoding/json.Unmarshaler
ListView represents an immutable sequence of array values defined by an
offset into a child array and a length.
(*ListView) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*ListView) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*ListView) ListValues() arrow.Array
(*ListView) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*ListView) Offset() int
(*ListView) Offsets() []int32
(*ListView) Release()
(*ListView) Retain()
(*ListView) Sizes() []int32
(*ListView) String() string
(*ListView) Validate() error
(*ListView) ValidateFull() error
(*ListView) ValueOffsets(i int) (start, end int64)
(*ListView) ValueStr(i int) string
*ListView : ListLike
*ListView : VarLenListLike
*ListView : github.com/apache/arrow-go/v18/arrow.Array[T]
*ListView : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*ListView : github.com/goccy/go-json.Marshaler
*ListView : encoding/json.Marshaler
*ListView : expvar.Var
*ListView : fmt.Stringer
func NewListViewData(data arrow.ArrayData) *ListView
func (*ListViewBuilder).NewListViewArray() (a *ListView)
(*ListViewBuilder) Append(v bool)
(*ListViewBuilder) AppendDimensions(offset int, listSize int)
(*ListViewBuilder) AppendEmptyValue()
(*ListViewBuilder) AppendEmptyValues(n int)
(*ListViewBuilder) AppendNull()
(*ListViewBuilder) AppendNulls(n int)
(*ListViewBuilder) AppendValueFromString(s string) error
(*ListViewBuilder) AppendValuesWithSizes(offsets []int32, sizes []int32, valid []bool)
(*ListViewBuilder) AppendWithSize(v bool, listSize int)
Cap returns the total number of elements that can be stored without allocating additional memory.
(*ListViewBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
NewArray creates a ListView array from the memory buffers used by the builder and
resets the ListViewBuilder so it can be used to build a new array.
NewListViewArray creates a ListView array from the memory buffers used by the builder
and resets the ListViewBuilder so it can be used to build a new array.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*ListViewBuilder) SetNull(i int)
(*ListViewBuilder) Type() arrow.DataType
(*ListViewBuilder) Unmarshal(dec *json.Decoder) error
(*ListViewBuilder) UnmarshalJSON(data []byte) error
(*ListViewBuilder) UnmarshalOne(dec *json.Decoder) error
(*ListViewBuilder) UnsafeAppendBoolToBitmap(isValid bool)
(*ListViewBuilder) ValueBuilder() Builder
*ListViewBuilder : Builder
*ListViewBuilder : ListLikeBuilder
*ListViewBuilder : VarLenListLikeBuilder
*ListViewBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*ListViewBuilder : github.com/goccy/go-json.Unmarshaler
*ListViewBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*ListViewBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ListLikeBuilder
*ListViewBuilder : encoding/json.Unmarshaler
func NewListViewBuilder(mem memory.Allocator, etype arrow.DataType) *ListViewBuilder
func NewListViewBuilderWithField(mem memory.Allocator, field arrow.Field) *ListViewBuilder
Map represents an immutable sequence of Key/Value structs. It is a
logical type that is implemented as a List<Struct: key, value>.
List *List
( Map) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
( Map) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Items returns the full Array of Item values, equivalent to grabbing
the Value field (the second field) of the child struct.
Keys returns the full Array of Key values, equivalent to grabbing
the key field of the child struct.
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.
Len returns the number of elements in the array.
( Map) ListValues() arrow.Array
( Map) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
( Map) Offset() int
( Map) Offsets() []int32
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( Map) String() string
( Map) ValueOffsets(i int) (start, end int64)
( Map) ValueStr(i int) string
*Map : ListLike
*Map : VarLenListLike
*Map : github.com/apache/arrow-go/v18/arrow.Array[T]
*Map : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
Map : github.com/goccy/go-json.Marshaler
Map : encoding/json.Marshaler
Map : expvar.Var
Map : fmt.Stringer
func NewMapData(data arrow.ArrayData) *Map
func (*MapBuilder).NewMapArray() (a *Map)
Append adds a new Map element to the array, calling Append(false) is
equivalent to calling AppendNull.
(*MapBuilder) AppendEmptyValue()
(*MapBuilder) AppendEmptyValues(n int)
AppendNull adds a null map entry to the array.
AppendNulls adds null map entry to the array.
(*MapBuilder) AppendValueFromString(s string) error
AppendValues is for bulk appending a group of elements with offsets provided
and validity booleans provided.
(*MapBuilder) AppendWithSize(v bool, _ int)
Cap returns the total number of elements that can be stored
without allocating additional memory.
IsNull returns if a previously appended value at a given index is null or not.
ItemBuilder returns a builder that can be used to populate the values that the
keys point to.
KeyBuilder returns a builder that can be used to populate the keys of the maps.
Len returns the current number of Maps that are in the builder
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1 for the sub builders (list, key, item).
Reserve enough space for n maps
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.
Retain increases the reference count by 1 for the sub-builders (list, key, item).
Retain may be called simultaneously from multiple goroutines.
(*MapBuilder) SetNull(i int)
(*MapBuilder) Type() arrow.DataType
(*MapBuilder) Unmarshal(dec *json.Decoder) error
(*MapBuilder) UnmarshalJSON(data []byte) error
(*MapBuilder) UnmarshalOne(dec *json.Decoder) error
(*MapBuilder) UnsafeAppendBoolToBitmap(v bool)
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.
*MapBuilder : Builder
*MapBuilder : ListLikeBuilder
*MapBuilder : VarLenListLikeBuilder
*MapBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*MapBuilder : github.com/goccy/go-json.Unmarshaler
*MapBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*MapBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ListLikeBuilder
*MapBuilder : encoding/json.Unmarshaler
func NewMapBuilder(mem memory.Allocator, keytype, itemtype arrow.DataType, keysSorted bool) *MapBuilder
func NewMapBuilderWithType(mem memory.Allocator, dt *arrow.MapType) *MapBuilder
(*MonthDayNanoDictionaryBuilder) Append(v arrow.MonthDayNanoInterval) error
(*MonthDayNanoDictionaryBuilder) AppendArray(arr arrow.Array) error
(*MonthDayNanoDictionaryBuilder) AppendEmptyValue()
(*MonthDayNanoDictionaryBuilder) AppendEmptyValues(n int)
(*MonthDayNanoDictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*MonthDayNanoDictionaryBuilder) AppendNull()
(*MonthDayNanoDictionaryBuilder) AppendNulls(n int)
(*MonthDayNanoDictionaryBuilder) AppendValueFromString(s string) error
(*MonthDayNanoDictionaryBuilder) Cap() int
(*MonthDayNanoDictionaryBuilder) DictionarySize() int
(*MonthDayNanoDictionaryBuilder) IndexBuilder() IndexBuilder
(*MonthDayNanoDictionaryBuilder) InsertDictValues(arr arrValues[arrow.MonthDayNanoInterval]) (err error)
(*MonthDayNanoDictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*MonthDayNanoDictionaryBuilder) NewArray() arrow.Array
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)
(*MonthDayNanoDictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*MonthDayNanoDictionaryBuilder) Release()
(*MonthDayNanoDictionaryBuilder) Reserve(n int)
(*MonthDayNanoDictionaryBuilder) ResetFull()
(*MonthDayNanoDictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*MonthDayNanoDictionaryBuilder) SetNull(i int)
(*MonthDayNanoDictionaryBuilder) Type() arrow.DataType
(*MonthDayNanoDictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*MonthDayNanoDictionaryBuilder) UnmarshalJSON(data []byte) error
(*MonthDayNanoDictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*MonthDayNanoDictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*MonthDayNanoDictionaryBuilder : Builder
*MonthDayNanoDictionaryBuilder : DictionaryBuilder
*MonthDayNanoDictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*MonthDayNanoDictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*MonthDayNanoDictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*MonthDayNanoDictionaryBuilder : encoding/json.Unmarshaler
A type which represents an immutable sequence of arrow.DayTimeInterval values.
(*MonthDayNanoInterval) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*MonthDayNanoInterval) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
MarshalJSON will marshal this array to a JSON array with elements
marshalled to the form {"months": #, "days": #, "nanoseconds": #}
(*MonthDayNanoInterval) MonthDayNanoIntervalValues() []arrow.MonthDayNanoInterval
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*MonthDayNanoInterval) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*MonthDayNanoInterval) String() string
(*MonthDayNanoInterval) Value(i int) arrow.MonthDayNanoInterval
(*MonthDayNanoInterval) ValueStr(i int) string
*MonthDayNanoInterval : github.com/apache/arrow-go/v18/arrow.Array[T]
*MonthDayNanoInterval : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*MonthDayNanoInterval : github.com/goccy/go-json.Marshaler
*MonthDayNanoInterval : encoding/json.Marshaler
*MonthDayNanoInterval : expvar.Var
*MonthDayNanoInterval : fmt.Stringer
func NewMonthDayNanoIntervalData(data arrow.ArrayData) *MonthDayNanoInterval
func (*MonthDayNanoIntervalBuilder).NewMonthDayNanoIntervalArray() (a *MonthDayNanoInterval)
(*MonthDayNanoIntervalBuilder) Append(v arrow.MonthDayNanoInterval)
(*MonthDayNanoIntervalBuilder) AppendEmptyValue()
(*MonthDayNanoIntervalBuilder) AppendEmptyValues(n int)
(*MonthDayNanoIntervalBuilder) AppendNull()
(*MonthDayNanoIntervalBuilder) AppendNulls(n int)
(*MonthDayNanoIntervalBuilder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*MonthDayNanoIntervalBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*MonthDayNanoIntervalBuilder) SetNull(i int)
(*MonthDayNanoIntervalBuilder) Type() arrow.DataType
(*MonthDayNanoIntervalBuilder) Unmarshal(dec *json.Decoder) 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": #}
(*MonthDayNanoIntervalBuilder) UnmarshalOne(dec *json.Decoder) error
(*MonthDayNanoIntervalBuilder) UnsafeAppend(v arrow.MonthDayNanoInterval)
(*MonthDayNanoIntervalBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*MonthDayNanoIntervalBuilder : Builder
*MonthDayNanoIntervalBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*MonthDayNanoIntervalBuilder : github.com/goccy/go-json.Unmarshaler
*MonthDayNanoIntervalBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*MonthDayNanoIntervalBuilder : encoding/json.Unmarshaler
func NewMonthDayNanoIntervalBuilder(mem memory.Allocator) *MonthDayNanoIntervalBuilder
A type which represents an immutable sequence of arrow.MonthInterval values.
(*MonthInterval) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*MonthInterval) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
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
(*MonthInterval) MonthIntervalValues() []arrow.MonthInterval
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*MonthInterval) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*MonthInterval) String() string
(*MonthInterval) Value(i int) arrow.MonthInterval
(*MonthInterval) ValueStr(i int) string
(*MonthInterval) Values() []arrow.MonthInterval
*MonthInterval : github.com/apache/arrow-go/v18/arrow.Array[T]
*MonthInterval : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*MonthInterval : github.com/goccy/go-json.Marshaler
*MonthInterval : encoding/json.Marshaler
*MonthInterval : expvar.Var
*MonthInterval : fmt.Stringer
func NewMonthIntervalData(data arrow.ArrayData) *MonthInterval
func (*MonthIntervalBuilder).NewMonthIntervalArray() (a *MonthInterval)
(*MonthIntervalBuilder) Append(v arrow.MonthInterval)
(*MonthIntervalBuilder) AppendEmptyValue()
(*MonthIntervalBuilder) AppendEmptyValues(n int)
(*MonthIntervalBuilder) AppendNull()
(*MonthIntervalBuilder) AppendNulls(n int)
(*MonthIntervalBuilder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*MonthIntervalBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*MonthIntervalBuilder) SetNull(i int)
(*MonthIntervalBuilder) Type() arrow.DataType
(*MonthIntervalBuilder) Unmarshal(dec *json.Decoder) 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.
(*MonthIntervalBuilder) UnmarshalOne(dec *json.Decoder) error
(*MonthIntervalBuilder) UnsafeAppend(v arrow.MonthInterval)
(*MonthIntervalBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*MonthIntervalBuilder : Builder
*MonthIntervalBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*MonthIntervalBuilder : github.com/goccy/go-json.Unmarshaler
*MonthIntervalBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*MonthIntervalBuilder : encoding/json.Unmarshaler
func NewMonthIntervalBuilder(mem memory.Allocator) *MonthIntervalBuilder
(*MonthIntervalDictionaryBuilder) Append(v arrow.MonthInterval) error
(*MonthIntervalDictionaryBuilder) AppendArray(arr arrow.Array) error
(*MonthIntervalDictionaryBuilder) AppendEmptyValue()
(*MonthIntervalDictionaryBuilder) AppendEmptyValues(n int)
(*MonthIntervalDictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*MonthIntervalDictionaryBuilder) AppendNull()
(*MonthIntervalDictionaryBuilder) AppendNulls(n int)
(*MonthIntervalDictionaryBuilder) AppendValueFromString(s string) error
(*MonthIntervalDictionaryBuilder) Cap() int
(*MonthIntervalDictionaryBuilder) DictionarySize() int
(*MonthIntervalDictionaryBuilder) IndexBuilder() IndexBuilder
(*MonthIntervalDictionaryBuilder) InsertDictValues(arr arrValues[arrow.MonthInterval]) (err error)
(*MonthIntervalDictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*MonthIntervalDictionaryBuilder) NewArray() arrow.Array
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)
(*MonthIntervalDictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*MonthIntervalDictionaryBuilder) Release()
(*MonthIntervalDictionaryBuilder) Reserve(n int)
(*MonthIntervalDictionaryBuilder) ResetFull()
(*MonthIntervalDictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*MonthIntervalDictionaryBuilder) SetNull(i int)
(*MonthIntervalDictionaryBuilder) Type() arrow.DataType
(*MonthIntervalDictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*MonthIntervalDictionaryBuilder) UnmarshalJSON(data []byte) error
(*MonthIntervalDictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*MonthIntervalDictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*MonthIntervalDictionaryBuilder : Builder
*MonthIntervalDictionaryBuilder : DictionaryBuilder
*MonthIntervalDictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*MonthIntervalDictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*MonthIntervalDictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*MonthIntervalDictionaryBuilder : encoding/json.Unmarshaler
Null represents an immutable, degenerate array with no physical storage.
(*Null) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Null) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Null) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Null) Offset() int
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Null) String() string
(*Null) Value(int) interface{}
(*Null) ValueStr(int) string
*Null : github.com/apache/arrow-go/v18/arrow.Array[T]
*Null : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Null : github.com/goccy/go-json.Marshaler
*Null : encoding/json.Marshaler
*Null : expvar.Var
*Null : fmt.Stringer
func NewNull(n int) *Null
func NewNullData(data arrow.ArrayData) *Null
func (*NullBuilder).NewNullArray() (a *Null)
(*NullBuilder) AppendEmptyValue()
(*NullBuilder) AppendEmptyValues(n int)
(*NullBuilder) AppendNull()
(*NullBuilder) AppendNulls(n int)
(*NullBuilder) AppendValueFromString(s string) error
Cap returns the total number of elements that can be stored without allocating additional memory.
(*NullBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
(*NullBuilder) Reserve(size int)
(*NullBuilder) Resize(size int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*NullBuilder) SetNull(i int)
(*NullBuilder) Type() arrow.DataType
(*NullBuilder) Unmarshal(dec *json.Decoder) error
(*NullBuilder) UnmarshalJSON(data []byte) error
(*NullBuilder) UnmarshalOne(dec *json.Decoder) error
(*NullBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*NullBuilder : Builder
*NullBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*NullBuilder : github.com/goccy/go-json.Unmarshaler
*NullBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*NullBuilder : encoding/json.Unmarshaler
func NewNullBuilder(mem memory.Allocator) *NullBuilder
(*NullDictionaryBuilder) AppendArray(arr arrow.Array) error
(*NullDictionaryBuilder) AppendEmptyValue()
(*NullDictionaryBuilder) AppendEmptyValues(n int)
(*NullDictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*NullDictionaryBuilder) AppendNull()
(*NullDictionaryBuilder) AppendNulls(n int)
(*NullDictionaryBuilder) AppendValueFromString(s string) error
(*NullDictionaryBuilder) Cap() int
(*NullDictionaryBuilder) DictionarySize() int
(*NullDictionaryBuilder) IndexBuilder() IndexBuilder
(*NullDictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*NullDictionaryBuilder) NewArray() arrow.Array
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)
(*NullDictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*NullDictionaryBuilder) Release()
(*NullDictionaryBuilder) Reserve(n int)
(*NullDictionaryBuilder) ResetFull()
(*NullDictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*NullDictionaryBuilder) SetNull(i int)
(*NullDictionaryBuilder) Type() arrow.DataType
(*NullDictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*NullDictionaryBuilder) UnmarshalJSON(data []byte) error
(*NullDictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*NullDictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*NullDictionaryBuilder : Builder
*NullDictionaryBuilder : DictionaryBuilder
*NullDictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*NullDictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*NullDictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*NullDictionaryBuilder : encoding/json.Unmarshaler
func WithAllocator(mem memory.Allocator) Option
func WithChunk(n int) Option
func NewJSONReader(r io.Reader, schema *arrow.Schema, opts ...Option) *JSONReader
RecordBuilder eases the process of building a Record, iteratively, from
a known Schema.
(*RecordBuilder) Field(i int) Builder
(*RecordBuilder) Fields() []Builder
Deprecated: Use [NewRecordBatch] instead.
NewRecordBatch creates a new record batch from the memory buffers and resets the
RecordBuilder so it can be used to build a new record batch.
The returned RecordBatch must be Release()'d after use.
NewRecordBatch panics if the fields' builder do not have the same length.
Release decreases the reference count by 1.
(*RecordBuilder) Reserve(size int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*RecordBuilder) Schema() *arrow.Schema
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.
*RecordBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*RecordBuilder : github.com/goccy/go-json.Unmarshaler
*RecordBuilder : encoding/json.Unmarshaler
func NewRecordBuilder(mem memory.Allocator, schema *arrow.Schema) *RecordBuilder
RecordReader reads a stream of records.
( RecordReader) Err() error
( RecordReader) Next() bool
Deprecated: Use [RecordBatch] instead.
( RecordReader) RecordBatch() arrow.RecordBatch
( RecordReader) Release()
( RecordReader) Retain()
( RecordReader) Schema() *arrow.Schema
*JSONReader
*TableReader
*github.com/apache/arrow-go/v18/arrow/ipc.Reader
RecordReader : github.com/apache/arrow-go/v18/arrow/compute/exec.ArrayIter[bool]
RecordReader : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
func NewRecordReader(schema *arrow.Schema, recs []arrow.RecordBatch) (RecordReader, error)
func ReaderFromIter(schema *arrow.Schema, itr iter.Seq2[arrow.RecordBatch, error]) RecordReader
func IterFromReader(rdr RecordReader) iter.Seq2[arrow.RecordBatch, error]
RunEndEncoded represents an array containing two children:
an array of int32 values defining the ends of each run of values
and an array of values
(*RunEndEncoded) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*RunEndEncoded) GetOneForMarshal(i int) interface{}
GetPhysicalIndex can be used to get the run-encoded value instead of costly LogicalValuesArray
in the following way:
r.Values().(valuetype).Value(r.GetPhysicalIndex(i))
(*RunEndEncoded) GetPhysicalLength() int
(*RunEndEncoded) GetPhysicalOffset() int
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
LogicalRunEndsArray returns an array holding the logical indexes
of each run end, only over the range of run end values relative
to the logical offset/length range of the parent array.
For arrays with an offset, this is not a slice of the existing
internal run ends array. Instead a new array is created with run-ends
that are adjusted so the new array can have an offset of 0. As a result
this method can be expensive to call for an array with a non-zero offset.
# Example
For this array:
RunEndEncoded: { Offset: 150, Length: 1500 }
RunEnds: [ 1, 2, 4, 6, 10, 1000, 1750, 2000 ]
Values: [ "a", "b", "c", "d", "e", "f", "g", "h" ]
LogicalRunEndsArray will return the following array:
[ 850, 1500 ]
This is because the offset of 150 tells us to skip all run-ends less
than 150 (by finding the physical offset), and we adjust the run-ends
accordingly (1000 - 150 = 850). The logical length of the array is 1500,
so we know we don't want to go past the 1750 run end. Thus the last
run-end is determined by doing: min(1750 - 150, 1500) = 1500.
# Note
The return from this needs to be Released
LogicalValuesArray returns an array holding the values of each
run, only over the range of run values inside the logical offset/length
range of the parent array.
# Example
For this array:
RunEndEncoded: { Offset: 150, Length: 1500 }
RunEnds: [ 1, 2, 4, 6, 10, 1000, 1750, 2000 ]
Values: [ "a", "b", "c", "d", "e", "f", "g", "h" ]
LogicalValuesArray will return the following array:
[ "f", "g" ]
This is because the offset of 150 tells it to skip the values until
"f" which corresponds with the logical offset (the run from 10 - 1000),
and stops after "g" because the length + offset goes to 1650 which is
within the run from 1000 - 1750, corresponding to the "g" value.
# Note
The return from this needs to be Released.
(*RunEndEncoded) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*RunEndEncoded) Offset() int
(*RunEndEncoded) Release()
(*RunEndEncoded) Retain()
(*RunEndEncoded) RunEndsArr() arrow.Array
(*RunEndEncoded) String() string
ValueStr will return the str representation of the value at the logical offset i.
(*RunEndEncoded) Values() arrow.Array
*RunEndEncoded : github.com/apache/arrow-go/v18/arrow.Array[T]
*RunEndEncoded : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*RunEndEncoded : github.com/goccy/go-json.Marshaler
*RunEndEncoded : encoding/json.Marshaler
*RunEndEncoded : expvar.Var
*RunEndEncoded : fmt.Stringer
func NewRunEndEncodedArray(runEnds, values arrow.Array, logicalLength, offset int) *RunEndEncoded
func NewRunEndEncodedData(data arrow.ArrayData) *RunEndEncoded
func (*RunEndEncodedBuilder).NewRunEndEncodedArray() *RunEndEncoded
func github.com/polarsignals/frostdb/pqarrow/arrowutils.TakeRunEndEncodedColumn(ctx context.Context, a *RunEndEncoded, idx int, arr []arrow.Array, indices *Int32) error
(*RunEndEncodedBuilder) Append(n uint64)
(*RunEndEncodedBuilder) AppendEmptyValue()
(*RunEndEncodedBuilder) AppendEmptyValues(n int)
(*RunEndEncodedBuilder) AppendNull()
(*RunEndEncodedBuilder) AppendNulls(n int)
(*RunEndEncodedBuilder) AppendRuns(runs []uint64)
AppendValueFromString can't be used in conjunction with UnmarshalOne
Cap returns the total number of elements that can be stored without allocating additional memory.
(*RunEndEncodedBuilder) ContinueRun(n uint64)
(*RunEndEncodedBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*RunEndEncodedBuilder) NewArray() arrow.Array
(*RunEndEncodedBuilder) NewRunEndEncodedArray() *RunEndEncoded
(*RunEndEncodedBuilder) NullN() int
(*RunEndEncodedBuilder) Release()
(*RunEndEncodedBuilder) Reserve(n int)
(*RunEndEncodedBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*RunEndEncodedBuilder) SetNull(i int)
(*RunEndEncodedBuilder) Type() arrow.DataType
Unmarshal can't be used in conjunction with AppendValueFromString (as it calls UnmarshalOne)
UnmarshalJSON can't be used in conjunction with AppendValueFromString (as it calls UnmarshalOne)
UnmarshalOne can't be used in conjunction with AppendValueFromString
(*RunEndEncodedBuilder) UnsafeAppendBoolToBitmap(isValid bool)
(*RunEndEncodedBuilder) ValueBuilder() Builder
*RunEndEncodedBuilder : Builder
*RunEndEncodedBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*RunEndEncodedBuilder : github.com/goccy/go-json.Unmarshaler
*RunEndEncodedBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*RunEndEncodedBuilder : encoding/json.Unmarshaler
func NewRunEndEncodedBuilder(mem memory.Allocator, runEnds, encoded arrow.DataType) *RunEndEncodedBuilder
SparseUnion represents an array where each logical value is taken from
a single child. A buffer of 8-bit type ids indicates which child a given
logical value is to be taken from. This is represented as the ChildID,
which is the index into the list of children.
In a sparse union, each child array will have the same length as the
union array itself, regardless of how many values in the union actually
refer to it.
Unlike most other arrays, unions do not have a top-level validity bitmap.
(*SparseUnion) ChildID(i int) int
(*SparseUnion) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*SparseUnion) Field(pos int) (result arrow.Array)
GetFlattenedField returns a child array, adjusting its validity bitmap
where the union array type codes don't match.
ie: the returned array will have a null in every index that it is
not referenced by union.
(*SparseUnion) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*SparseUnion) MarshalJSON() ([]byte, error)
(*SparseUnion) Mode() arrow.UnionMode
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*SparseUnion) NumFields() int
(*SparseUnion) Offset() int
(*SparseUnion) RawTypeCodes() []arrow.UnionTypeCode
(*SparseUnion) Release()
(*SparseUnion) Retain()
(*SparseUnion) String() string
(*SparseUnion) TypeCode(i int) arrow.UnionTypeCode
(*SparseUnion) TypeCodes() *memory.Buffer
(*SparseUnion) UnionType() arrow.UnionType
(*SparseUnion) Validate() error
(*SparseUnion) ValidateFull() error
(*SparseUnion) ValueStr(i int) string
*SparseUnion : Union
*SparseUnion : github.com/apache/arrow-go/v18/arrow.Array[T]
*SparseUnion : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*SparseUnion : github.com/goccy/go-json.Marshaler
*SparseUnion : encoding/json.Marshaler
*SparseUnion : expvar.Var
*SparseUnion : fmt.Stringer
func NewSparseUnion(dt *arrow.SparseUnionType, length int, children []arrow.Array, typeIDs *memory.Buffer, offset int) *SparseUnion
func NewSparseUnionData(data arrow.ArrayData) *SparseUnion
func NewSparseUnionFromArrays(typeIDs arrow.Array, children []arrow.Array, codes ...arrow.UnionTypeCode) (*SparseUnion, error)
func NewSparseUnionFromArraysWithFieldCodes(typeIDs arrow.Array, children []arrow.Array, fields []string, codes []arrow.UnionTypeCode) (*SparseUnion, error)
func NewSparseUnionFromArraysWithFields(typeIDs arrow.Array, children []arrow.Array, fields []string) (*SparseUnion, error)
func (*SparseUnionBuilder).NewSparseUnionArray() (a *SparseUnion)
SparseUnionBuilder is used to build a Sparse Union array using the Append
methods. You can also add new types to the union on the fly by using
AppendChild.
Keep in mind: All children of a SparseUnion should be the same length
as the union itself. If you add new children with AppendChild, ensure
that they have the correct number of preceding elements that have been
added to the builder beforehand.
Append appends an element to the UnionArray and must be followed up
by an append to the appropriate child builder. The parameter should
be the type id of the child to which the next value will be appended.
After appending to the corresponding child builder, all other child
builders should have a null or empty value appended to them (although
this is not enforced and any value is theoretically allowed and will be
ignored).
( SparseUnionBuilder) AppendChild(newChild Builder, fieldName string) arrow.UnionTypeCode
AppendEmptyValue appends an empty value (implementation defined)
to each child, and appends the type of the first typecode to the typeid
buffer.
AppendEmptyValues is identical to calling AppendEmptyValue() n times,
except it pre-allocates first so it is more efficient.
AppendNull will append a null to the first child and an empty value
(implementation-defined) to the rest of the children.
AppendNulls is identical to calling AppendNull() n times, except
it will pre-allocate with reserve for all the nulls beforehand.
(*SparseUnionBuilder) AppendValueFromString(s string) error
Cap returns the total number of elements that can be stored without allocating additional memory.
( SparseUnionBuilder) Child(idx int) Builder
( SparseUnionBuilder) IsNull(i int) bool
Len returns the current number of elements in the builder.
( SparseUnionBuilder) Mode() arrow.UnionMode
(*SparseUnionBuilder) NewArray() arrow.Array
(*SparseUnionBuilder) NewSparseUnionArray() (a *SparseUnion)
NullN returns the number of null values in the array builder.
( SparseUnionBuilder) NumChildren() int
( SparseUnionBuilder) Release()
(*SparseUnionBuilder) Reserve(n int)
(*SparseUnionBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( SparseUnionBuilder) SetNull(i int)
( SparseUnionBuilder) Type() arrow.DataType
(*SparseUnionBuilder) Unmarshal(dec *json.Decoder) error
(*SparseUnionBuilder) UnmarshalJSON(data []byte) (err error)
(*SparseUnionBuilder) UnmarshalOne(dec *json.Decoder) error
( SparseUnionBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*SparseUnionBuilder : Builder
*SparseUnionBuilder : UnionBuilder
SparseUnionBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*SparseUnionBuilder : github.com/goccy/go-json.Unmarshaler
*SparseUnionBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*SparseUnionBuilder : encoding/json.Unmarshaler
func NewEmptySparseUnionBuilder(mem memory.Allocator) *SparseUnionBuilder
func NewSparseUnionBuilder(mem memory.Allocator, typ *arrow.SparseUnionType) *SparseUnionBuilder
func NewSparseUnionBuilderWithBuilders(mem memory.Allocator, typ *arrow.SparseUnionType, children []Builder) *SparseUnionBuilder
String represents an immutable sequence of variable-length UTF-8 strings.
(*String) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*String) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*String) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*String) Offset() int
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.
Reset resets the String with a different set of Data.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*String) String() string
Value returns the slice at index i. This value should not be mutated.
(*String) ValueBytes() []byte
(*String) ValueLen(i int) int
ValueOffset returns the offset of the value at index i.
(*String) ValueOffset64(i int) int64
(*String) ValueOffsets() []int32
(*String) ValueStr(i int) string
*String : BinaryLike
*String : StringLike
*String : github.com/apache/arrow-go/v18/arrow.Array[T]
*String : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*String : github.com/goccy/go-json.Marshaler
*String : encoding/json.Marshaler
*String : expvar.Var
*String : fmt.Stringer
func NewStringData(data arrow.ArrayData) *String
func (*StringBuilder).NewStringArray() (a *String)
func (*BinaryDictionaryBuilder).InsertStringDictValues(arr *String) (err error)
func github.com/polarsignals/frostdb/query/physicalplan.StringArrayScalarRegexMatch(left *String, right *regexp.Regexp) (*physicalplan.Bitmap, error)
func github.com/polarsignals/frostdb/query/physicalplan.StringArrayScalarRegexNotMatch(left *String, right *regexp.Regexp) (*physicalplan.Bitmap, error)
A StringBuilder is used to build a String array using the Append methods.
BinaryBuilder *BinaryBuilder
Append appends a string to the builder.
( StringBuilder) AppendEmptyValue()
( StringBuilder) AppendEmptyValues(n int)
( StringBuilder) AppendNull()
( StringBuilder) AppendNulls(n int)
( StringBuilder) AppendString(v string)
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.
( StringBuilder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
DataCap returns the total number of bytes that can be stored
without allocating additional memory.
DataLen returns the number of bytes in the data array.
( StringBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
( StringBuilder) NewLargeBinaryArray() (a *LargeBinary)
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.
NullN returns the number of null values in the array builder.
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.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
ReserveData ensures there is enough space for appending n bytes
by checking the capacity and resizing the data buffer if necessary.
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.
( StringBuilder) ResizeData(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( StringBuilder) SetNull(i int)
(*StringBuilder) Type() arrow.DataType
(*StringBuilder) Unmarshal(dec *json.Decoder) error
(*StringBuilder) UnmarshalJSON(data []byte) error
(*StringBuilder) UnmarshalOne(dec *json.Decoder) error
( StringBuilder) UnsafeAppend(v []byte)
( StringBuilder) UnsafeAppendBoolToBitmap(isValid bool)
Value returns the string at index i.
*StringBuilder : Builder
*StringBuilder : StringLikeBuilder
StringBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*StringBuilder : github.com/goccy/go-json.Unmarshaler
*StringBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*StringBuilder : encoding/json.Unmarshaler
func NewStringBuilder(mem memory.Allocator) *StringBuilder
( StringLike) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
Get single value to be marshalled with `json.Marshal`
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
( StringLike) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( StringLike) String() string
( StringLike) Value(int) string
( StringLike) ValueLen(int) int
ValueStr returns the value at index as a string.
*LargeString
*String
*StringView
StringLike : github.com/apache/arrow-go/v18/arrow.Array[T]
StringLike : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
StringLike : github.com/goccy/go-json.Marshaler
StringLike : encoding/json.Marshaler
StringLike : expvar.Var
StringLike : fmt.Stringer
( StringLikeBuilder) Append(string)
AppendEmptyValue adds a new zero value of the appropriate type
AppendEmptyValues adds new n zero values of the appropriate type
AppendNull adds a new null value to the array being built.
AppendNulls adds new n null values to the array being built.
AppendValueFromString adds a new value from a string. Inverse of array.ValueStr(i int) string
( StringLikeBuilder) AppendValues([]string, []bool)
Cap returns the total number of elements that can be stored
without allocating additional memory.
IsNull returns if a previously appended value at a given index is null or not.
Len returns the number of elements in the array builder.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
( StringLikeBuilder) ReserveData(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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
SetNull sets the value at index i to null.
Type returns the datatype that this is building
( StringLikeBuilder) Unmarshal(*json.Decoder) error
( StringLikeBuilder) UnmarshalJSON([]byte) error
( StringLikeBuilder) UnmarshalOne(*json.Decoder) error
( StringLikeBuilder) UnsafeAppend([]byte)
( StringLikeBuilder) UnsafeAppendBoolToBitmap(bool)
*LargeStringBuilder
*StringBuilder
*StringViewBuilder
StringLikeBuilder : Builder
StringLikeBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
StringLikeBuilder : github.com/goccy/go-json.Unmarshaler
StringLikeBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
StringLikeBuilder : encoding/json.Unmarshaler
(*StringView) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*StringView) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*StringView) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*StringView) Offset() int
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.
Reset resets the String with a different set of Data.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*StringView) String() string
(*StringView) Value(i int) string
(*StringView) ValueHeader(i int) *arrow.ViewHeader
(*StringView) ValueLen(i int) int
(*StringView) ValueStr(i int) string
*StringView : StringLike
*StringView : ViewLike
*StringView : github.com/apache/arrow-go/v18/arrow.Array[T]
*StringView : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*StringView : github.com/goccy/go-json.Marshaler
*StringView : encoding/json.Marshaler
*StringView : expvar.Var
*StringView : fmt.Stringer
func NewStringViewData(data arrow.ArrayData) *StringView
func (*StringViewBuilder).NewStringViewArray() (a *StringView)
BinaryViewBuilder *BinaryViewBuilder
(*StringViewBuilder) Append(v string)
( StringViewBuilder) AppendEmptyValue()
( StringViewBuilder) AppendEmptyValues(n int)
( StringViewBuilder) AppendNull()
( StringViewBuilder) AppendNulls(n int)
AppendString is identical to Append, only accepting a string instead
of a byte slice, avoiding the extra copy that would occur if you simply
did []byte(v).
This is different than AppendValueFromString which exists for the
Builder interface, in that this expects raw binary data which is
appended unmodified. AppendValueFromString expects base64 encoded binary
data instead.
( StringViewBuilder) AppendStringValues(v []string, valid []bool)
AppendValueFromString is paired with ValueStr for fulfilling the
base Builder interface. This is intended to read in a human-readable
string such as from CSV or JSON and append it to the array.
For Binary values are expected to be base64 encoded (and will be
decoded as such before being appended).
(*StringViewBuilder) AppendValues(v []string, valid []bool)
Cap returns the total number of elements that can be stored without allocating additional memory.
( StringViewBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*StringViewBuilder) NewArray() arrow.Array
( StringViewBuilder) NewBinaryViewArray() (a *BinaryView)
(*StringViewBuilder) NewStringViewArray() (a *StringView)
NullN returns the number of null values in the array builder.
( StringViewBuilder) Release()
( StringViewBuilder) Reserve(n int)
( StringViewBuilder) ReserveData(length int)
( StringViewBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( StringViewBuilder) SetBlockSize(sz uint)
( StringViewBuilder) SetNull(i int)
( StringViewBuilder) Type() arrow.DataType
(*StringViewBuilder) Unmarshal(dec *json.Decoder) error
(*StringViewBuilder) UnmarshalJSON(data []byte) error
(*StringViewBuilder) UnmarshalOne(dec *json.Decoder) error
( StringViewBuilder) UnsafeAppend(v []byte)
( StringViewBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*StringViewBuilder : Builder
*StringViewBuilder : StringLikeBuilder
StringViewBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*StringViewBuilder : github.com/goccy/go-json.Unmarshaler
*StringViewBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*StringViewBuilder : encoding/json.Unmarshaler
func NewStringViewBuilder(mem memory.Allocator) *StringViewBuilder
Struct represents an ordered sequence of relative types.
(*Struct) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Struct) Field(i int) arrow.Array
(*Struct) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Struct) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Struct) NumField() int
(*Struct) Offset() int
(*Struct) Release()
(*Struct) Retain()
(*Struct) String() string
ValueStr returns the string representation (as json) of the value at index i.
*Struct : github.com/apache/arrow-go/v18/arrow.Array[T]
*Struct : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Struct : github.com/goccy/go-json.Marshaler
*Struct : encoding/json.Marshaler
*Struct : expvar.Var
*Struct : fmt.Stringer
func NewStructArray(cols []arrow.Array, names []string) (*Struct, error)
func NewStructArrayWithFields(cols []arrow.Array, fields []arrow.Field) (*Struct, error)
func NewStructArrayWithFieldsAndNulls(cols []arrow.Array, fields []arrow.Field, nullBitmap *memory.Buffer, nullCount int, offset int) (*Struct, error)
func NewStructArrayWithNulls(cols []arrow.Array, names []string, nullBitmap *memory.Buffer, nullCount int, offset int) (*Struct, error)
func NewStructData(data arrow.ArrayData) *Struct
func RecordToStructArray(rec arrow.RecordBatch) *Struct
func (*StructBuilder).NewStructArray() (a *Struct)
func RecordFromStructArray(in *Struct, schema *arrow.Schema) arrow.RecordBatch
func github.com/polarsignals/frostdb/pqarrow/arrowutils.TakeStructColumn(ctx context.Context, a *Struct, idx int, arr []arrow.Array, indices *Int32) error
(*StructBuilder) Append(v bool)
(*StructBuilder) AppendEmptyValue()
(*StructBuilder) AppendEmptyValues(n int)
(*StructBuilder) AppendNull()
(*StructBuilder) AppendNulls(n int)
(*StructBuilder) AppendValueFromString(s string) error
(*StructBuilder) AppendValues(valids []bool)
Cap returns the total number of elements that can be stored without allocating additional memory.
(*StructBuilder) FieldBuilder(i int) Builder
(*StructBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
(*StructBuilder) NumField() int
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*StructBuilder) SetNull(i int)
(*StructBuilder) Type() arrow.DataType
(*StructBuilder) Unmarshal(dec *json.Decoder) error
(*StructBuilder) UnmarshalJSON(data []byte) error
(*StructBuilder) UnmarshalOne(dec *json.Decoder) error
(*StructBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*StructBuilder : Builder
*StructBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*StructBuilder : github.com/goccy/go-json.Unmarshaler
*StructBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*StructBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ListLikeBuilder
*StructBuilder : encoding/json.Unmarshaler
func NewStructBuilder(mem memory.Allocator, dtype *arrow.StructType) *StructBuilder
TableReader is a Record iterator over a (possibly chunked) Table
(*TableReader) Err() error
(*TableReader) Next() bool
Deprecated: Use [RecordBatch] instead.
(*TableReader) RecordBatch() arrow.RecordBatch
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*TableReader) Schema() *arrow.Schema
*TableReader : RecordReader
*TableReader : github.com/apache/arrow-go/v18/arrow/compute/exec.ArrayIter[bool]
*TableReader : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
func NewTableReader(tbl arrow.Table, chunkSize int64) *TableReader
(*Time32) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Time32) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Time32) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Time32) Offset() int
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.
(*Time32) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Time32) String() string
(*Time32) Time32Values() []arrow.Time32
(*Time32) Value(i int) arrow.Time32
(*Time32) ValueStr(i int) string
(*Time32) Values() []arrow.Time32
*Time32 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Time32 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Time32 : github.com/goccy/go-json.Marshaler
*Time32 : encoding/json.Marshaler
*Time32 : expvar.Var
*Time32 : fmt.Stringer
func NewTime32Data(data arrow.ArrayData) *Time32
func (*Time32Builder).NewTime32Array() (a *Time32)
(*Time32Builder) Append(v arrow.Time32)
(*Time32Builder) AppendEmptyValue()
(*Time32Builder) AppendEmptyValues(n int)
(*Time32Builder) AppendNull()
(*Time32Builder) AppendNulls(n int)
(*Time32Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Time32Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Time32Builder) SetNull(i int)
(*Time32Builder) Type() arrow.DataType
(*Time32Builder) Unmarshal(dec *json.Decoder) error
(*Time32Builder) UnmarshalJSON(data []byte) error
(*Time32Builder) UnmarshalOne(dec *json.Decoder) error
(*Time32Builder) UnsafeAppend(v arrow.Time32)
(*Time32Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Time32Builder) Value(i int) arrow.Time32
*Time32Builder : Builder
*Time32Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Time32Builder : github.com/goccy/go-json.Unmarshaler
*Time32Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Time32Builder : encoding/json.Unmarshaler
func NewTime32Builder(mem memory.Allocator, dtype *arrow.Time32Type) *Time32Builder
(*Time32DictionaryBuilder) Append(v arrow.Time32) error
(*Time32DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Time32DictionaryBuilder) AppendEmptyValue()
(*Time32DictionaryBuilder) AppendEmptyValues(n int)
(*Time32DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Time32DictionaryBuilder) AppendNull()
(*Time32DictionaryBuilder) AppendNulls(n int)
(*Time32DictionaryBuilder) AppendValueFromString(s string) error
(*Time32DictionaryBuilder) Cap() int
(*Time32DictionaryBuilder) DictionarySize() int
(*Time32DictionaryBuilder) IndexBuilder() IndexBuilder
(*Time32DictionaryBuilder) InsertDictValues(arr arrValues[arrow.Time32]) (err error)
(*Time32DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Time32DictionaryBuilder) NewArray() arrow.Array
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)
(*Time32DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Time32DictionaryBuilder) Release()
(*Time32DictionaryBuilder) Reserve(n int)
(*Time32DictionaryBuilder) ResetFull()
(*Time32DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Time32DictionaryBuilder) SetNull(i int)
(*Time32DictionaryBuilder) Type() arrow.DataType
(*Time32DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Time32DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Time32DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Time32DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Time32DictionaryBuilder : Builder
*Time32DictionaryBuilder : DictionaryBuilder
*Time32DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Time32DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Time32DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Time32DictionaryBuilder : encoding/json.Unmarshaler
(*Time64) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Time64) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Time64) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Time64) Offset() int
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.
(*Time64) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Time64) String() string
(*Time64) Time64Values() []arrow.Time64
(*Time64) Value(i int) arrow.Time64
(*Time64) ValueStr(i int) string
(*Time64) Values() []arrow.Time64
*Time64 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Time64 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Time64 : github.com/goccy/go-json.Marshaler
*Time64 : encoding/json.Marshaler
*Time64 : expvar.Var
*Time64 : fmt.Stringer
func NewTime64Data(data arrow.ArrayData) *Time64
func (*Time64Builder).NewTime64Array() (a *Time64)
(*Time64Builder) Append(v arrow.Time64)
(*Time64Builder) AppendEmptyValue()
(*Time64Builder) AppendEmptyValues(n int)
(*Time64Builder) AppendNull()
(*Time64Builder) AppendNulls(n int)
(*Time64Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Time64Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Time64Builder) SetNull(i int)
(*Time64Builder) Type() arrow.DataType
(*Time64Builder) Unmarshal(dec *json.Decoder) error
(*Time64Builder) UnmarshalJSON(data []byte) error
(*Time64Builder) UnmarshalOne(dec *json.Decoder) error
(*Time64Builder) UnsafeAppend(v arrow.Time64)
(*Time64Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Time64Builder) Value(i int) arrow.Time64
*Time64Builder : Builder
*Time64Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Time64Builder : github.com/goccy/go-json.Unmarshaler
*Time64Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Time64Builder : encoding/json.Unmarshaler
func NewTime64Builder(mem memory.Allocator, dtype *arrow.Time64Type) *Time64Builder
(*Time64DictionaryBuilder) Append(v arrow.Time64) error
(*Time64DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Time64DictionaryBuilder) AppendEmptyValue()
(*Time64DictionaryBuilder) AppendEmptyValues(n int)
(*Time64DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Time64DictionaryBuilder) AppendNull()
(*Time64DictionaryBuilder) AppendNulls(n int)
(*Time64DictionaryBuilder) AppendValueFromString(s string) error
(*Time64DictionaryBuilder) Cap() int
(*Time64DictionaryBuilder) DictionarySize() int
(*Time64DictionaryBuilder) IndexBuilder() IndexBuilder
(*Time64DictionaryBuilder) InsertDictValues(arr arrValues[arrow.Time64]) (err error)
(*Time64DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Time64DictionaryBuilder) NewArray() arrow.Array
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)
(*Time64DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Time64DictionaryBuilder) Release()
(*Time64DictionaryBuilder) Reserve(n int)
(*Time64DictionaryBuilder) ResetFull()
(*Time64DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Time64DictionaryBuilder) SetNull(i int)
(*Time64DictionaryBuilder) Type() arrow.DataType
(*Time64DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Time64DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Time64DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Time64DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Time64DictionaryBuilder : Builder
*Time64DictionaryBuilder : DictionaryBuilder
*Time64DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Time64DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Time64DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Time64DictionaryBuilder : encoding/json.Unmarshaler
Timestamp represents an immutable sequence of arrow.Timestamp values.
(*Timestamp) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Timestamp) GetOneForMarshal(i int) interface{}
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Timestamp) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Timestamp) Offset() int
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.
Reset resets the array for re-use.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
String returns a string representation of the array.
TimestampValues returns the values.
Value returns the value at the specified index.
(*Timestamp) ValueStr(i int) string
(*Timestamp) Values() []arrow.Timestamp
*Timestamp : github.com/apache/arrow-go/v18/arrow.Array[T]
*Timestamp : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Timestamp : github.com/goccy/go-json.Marshaler
*Timestamp : encoding/json.Marshaler
*Timestamp : expvar.Var
*Timestamp : fmt.Stringer
func NewTimestampData(data arrow.ArrayData) *Timestamp
func (*TimestampBuilder).NewTimestampArray() (a *Timestamp)
(*TimestampBuilder) Append(v arrow.Timestamp)
(*TimestampBuilder) AppendEmptyValue()
(*TimestampBuilder) AppendEmptyValues(n int)
(*TimestampBuilder) AppendNull()
(*TimestampBuilder) AppendNulls(n int)
(*TimestampBuilder) AppendTime(t time.Time)
(*TimestampBuilder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*TimestampBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*TimestampBuilder) SetNull(i int)
(*TimestampBuilder) Type() arrow.DataType
(*TimestampBuilder) Unmarshal(dec *json.Decoder) error
(*TimestampBuilder) UnmarshalJSON(data []byte) error
(*TimestampBuilder) UnmarshalOne(dec *json.Decoder) error
(*TimestampBuilder) UnsafeAppend(v arrow.Timestamp)
(*TimestampBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*TimestampBuilder : Builder
*TimestampBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*TimestampBuilder : github.com/goccy/go-json.Unmarshaler
*TimestampBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*TimestampBuilder : encoding/json.Unmarshaler
func NewTimestampBuilder(mem memory.Allocator, dtype *arrow.TimestampType) *TimestampBuilder
(*TimestampDictionaryBuilder) Append(v arrow.Timestamp) error
(*TimestampDictionaryBuilder) AppendArray(arr arrow.Array) error
(*TimestampDictionaryBuilder) AppendEmptyValue()
(*TimestampDictionaryBuilder) AppendEmptyValues(n int)
(*TimestampDictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*TimestampDictionaryBuilder) AppendNull()
(*TimestampDictionaryBuilder) AppendNulls(n int)
(*TimestampDictionaryBuilder) AppendValueFromString(s string) error
(*TimestampDictionaryBuilder) Cap() int
(*TimestampDictionaryBuilder) DictionarySize() int
(*TimestampDictionaryBuilder) IndexBuilder() IndexBuilder
(*TimestampDictionaryBuilder) InsertDictValues(arr arrValues[arrow.Timestamp]) (err error)
(*TimestampDictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*TimestampDictionaryBuilder) NewArray() arrow.Array
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)
(*TimestampDictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*TimestampDictionaryBuilder) Release()
(*TimestampDictionaryBuilder) Reserve(n int)
(*TimestampDictionaryBuilder) ResetFull()
(*TimestampDictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*TimestampDictionaryBuilder) SetNull(i int)
(*TimestampDictionaryBuilder) Type() arrow.DataType
(*TimestampDictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*TimestampDictionaryBuilder) UnmarshalJSON(data []byte) error
(*TimestampDictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*TimestampDictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*TimestampDictionaryBuilder : Builder
*TimestampDictionaryBuilder : DictionaryBuilder
*TimestampDictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*TimestampDictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*TimestampDictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*TimestampDictionaryBuilder : encoding/json.Unmarshaler
(*Uint16) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Uint16) GetOneForMarshal(i int) any
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Uint16) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Uint16) Offset() int
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.
(*Uint16) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Uint16) String() string
(*Uint16) Uint16Values() []uint16
(*Uint16) Value(i int) uint16
(*Uint16) ValueStr(i int) string
(*Uint16) Values() []uint16
*Uint16 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Uint16 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Uint16 : github.com/goccy/go-json.Marshaler
*Uint16 : encoding/json.Marshaler
*Uint16 : expvar.Var
*Uint16 : fmt.Stringer
func NewUint16Data(data arrow.ArrayData) *Uint16
func (*Uint16Builder).NewUint16Array() (a *Uint16)
(*Uint16Builder) Append(v uint16)
(*Uint16Builder) AppendEmptyValue()
(*Uint16Builder) AppendEmptyValues(n int)
(*Uint16Builder) AppendNull()
(*Uint16Builder) AppendNulls(n int)
(*Uint16Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Uint16Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Uint16Builder) SetNull(i int)
(*Uint16Builder) Type() arrow.DataType
(*Uint16Builder) Unmarshal(dec *json.Decoder) error
(*Uint16Builder) UnmarshalJSON(data []byte) error
(*Uint16Builder) UnmarshalOne(dec *json.Decoder) error
(*Uint16Builder) UnsafeAppend(v uint16)
(*Uint16Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Uint16Builder) Value(i int) uint16
*Uint16Builder : Builder
*Uint16Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Uint16Builder : github.com/goccy/go-json.Unmarshaler
*Uint16Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Uint16Builder : encoding/json.Unmarshaler
func NewUint16Builder(mem memory.Allocator) *Uint16Builder
(*Uint16DictionaryBuilder) Append(v uint16) error
(*Uint16DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Uint16DictionaryBuilder) AppendEmptyValue()
(*Uint16DictionaryBuilder) AppendEmptyValues(n int)
(*Uint16DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Uint16DictionaryBuilder) AppendNull()
(*Uint16DictionaryBuilder) AppendNulls(n int)
(*Uint16DictionaryBuilder) AppendValueFromString(s string) error
(*Uint16DictionaryBuilder) Cap() int
(*Uint16DictionaryBuilder) DictionarySize() int
(*Uint16DictionaryBuilder) IndexBuilder() IndexBuilder
(*Uint16DictionaryBuilder) InsertDictValues(arr arrValues[uint16]) (err error)
(*Uint16DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Uint16DictionaryBuilder) NewArray() arrow.Array
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)
(*Uint16DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Uint16DictionaryBuilder) Release()
(*Uint16DictionaryBuilder) Reserve(n int)
(*Uint16DictionaryBuilder) ResetFull()
(*Uint16DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Uint16DictionaryBuilder) SetNull(i int)
(*Uint16DictionaryBuilder) Type() arrow.DataType
(*Uint16DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Uint16DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Uint16DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Uint16DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Uint16DictionaryBuilder : Builder
*Uint16DictionaryBuilder : DictionaryBuilder
*Uint16DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Uint16DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Uint16DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Uint16DictionaryBuilder : encoding/json.Unmarshaler
(*Uint32) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Uint32) GetOneForMarshal(i int) any
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Uint32) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Uint32) Offset() int
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.
(*Uint32) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Uint32) String() string
(*Uint32) Uint32Values() []uint32
(*Uint32) Value(i int) uint32
(*Uint32) ValueStr(i int) string
(*Uint32) Values() []uint32
*Uint32 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Uint32 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Uint32 : github.com/goccy/go-json.Marshaler
*Uint32 : encoding/json.Marshaler
*Uint32 : expvar.Var
*Uint32 : fmt.Stringer
func NewUint32Data(data arrow.ArrayData) *Uint32
func (*Uint32Builder).NewUint32Array() (a *Uint32)
(*Uint32Builder) Append(v uint32)
(*Uint32Builder) AppendEmptyValue()
(*Uint32Builder) AppendEmptyValues(n int)
(*Uint32Builder) AppendNull()
(*Uint32Builder) AppendNulls(n int)
(*Uint32Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Uint32Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Uint32Builder) SetNull(i int)
(*Uint32Builder) Type() arrow.DataType
(*Uint32Builder) Unmarshal(dec *json.Decoder) error
(*Uint32Builder) UnmarshalJSON(data []byte) error
(*Uint32Builder) UnmarshalOne(dec *json.Decoder) error
(*Uint32Builder) UnsafeAppend(v uint32)
(*Uint32Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Uint32Builder) Value(i int) uint32
*Uint32Builder : Builder
*Uint32Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Uint32Builder : github.com/goccy/go-json.Unmarshaler
*Uint32Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Uint32Builder : encoding/json.Unmarshaler
func NewUint32Builder(mem memory.Allocator) *Uint32Builder
(*Uint32DictionaryBuilder) Append(v uint32) error
(*Uint32DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Uint32DictionaryBuilder) AppendEmptyValue()
(*Uint32DictionaryBuilder) AppendEmptyValues(n int)
(*Uint32DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Uint32DictionaryBuilder) AppendNull()
(*Uint32DictionaryBuilder) AppendNulls(n int)
(*Uint32DictionaryBuilder) AppendValueFromString(s string) error
(*Uint32DictionaryBuilder) Cap() int
(*Uint32DictionaryBuilder) DictionarySize() int
(*Uint32DictionaryBuilder) IndexBuilder() IndexBuilder
(*Uint32DictionaryBuilder) InsertDictValues(arr arrValues[uint32]) (err error)
(*Uint32DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Uint32DictionaryBuilder) NewArray() arrow.Array
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)
(*Uint32DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Uint32DictionaryBuilder) Release()
(*Uint32DictionaryBuilder) Reserve(n int)
(*Uint32DictionaryBuilder) ResetFull()
(*Uint32DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Uint32DictionaryBuilder) SetNull(i int)
(*Uint32DictionaryBuilder) Type() arrow.DataType
(*Uint32DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Uint32DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Uint32DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Uint32DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Uint32DictionaryBuilder : Builder
*Uint32DictionaryBuilder : DictionaryBuilder
*Uint32DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Uint32DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Uint32DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Uint32DictionaryBuilder : encoding/json.Unmarshaler
(*Uint64) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Uint64) GetOneForMarshal(i int) any
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Uint64) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Uint64) Offset() int
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.
(*Uint64) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Uint64) String() string
(*Uint64) Uint64Values() []uint64
(*Uint64) Value(i int) uint64
(*Uint64) ValueStr(i int) string
(*Uint64) Values() []uint64
*Uint64 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Uint64 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Uint64 : github.com/goccy/go-json.Marshaler
*Uint64 : encoding/json.Marshaler
*Uint64 : expvar.Var
*Uint64 : fmt.Stringer
func NewUint64Data(data arrow.ArrayData) *Uint64
func (*Uint64Builder).NewUint64Array() (a *Uint64)
func github.com/polarsignals/frostdb/query/physicalplan.AddUint64s(mem memory.Allocator, left, right *Uint64) *Uint64
func github.com/polarsignals/frostdb/query/physicalplan.DivUint64s(mem memory.Allocator, left, right *Uint64) *Uint64
func github.com/polarsignals/frostdb/query/physicalplan.MulUint64s(mem memory.Allocator, left, right *Uint64) *Uint64
func github.com/polarsignals/frostdb/query/physicalplan.SubUint64s(mem memory.Allocator, left, right *Uint64) *Uint64
func github.com/apache/arrow-go/v18/arrow/math.Uint64Funcs.Sum(a *Uint64) uint64
func github.com/polarsignals/frostdb/query/physicalplan.AddUint64s(mem memory.Allocator, left, right *Uint64) *Uint64
func github.com/polarsignals/frostdb/query/physicalplan.DivUint64s(mem memory.Allocator, left, right *Uint64) *Uint64
func github.com/polarsignals/frostdb/query/physicalplan.MulUint64s(mem memory.Allocator, left, right *Uint64) *Uint64
func github.com/polarsignals/frostdb/query/physicalplan.SubUint64s(mem memory.Allocator, left, right *Uint64) *Uint64
(*Uint64Builder) Append(v uint64)
(*Uint64Builder) AppendEmptyValue()
(*Uint64Builder) AppendEmptyValues(n int)
(*Uint64Builder) AppendNull()
(*Uint64Builder) AppendNulls(n int)
(*Uint64Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Uint64Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Uint64Builder) SetNull(i int)
(*Uint64Builder) Type() arrow.DataType
(*Uint64Builder) Unmarshal(dec *json.Decoder) error
(*Uint64Builder) UnmarshalJSON(data []byte) error
(*Uint64Builder) UnmarshalOne(dec *json.Decoder) error
(*Uint64Builder) UnsafeAppend(v uint64)
(*Uint64Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Uint64Builder) Value(i int) uint64
*Uint64Builder : Builder
*Uint64Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Uint64Builder : github.com/goccy/go-json.Unmarshaler
*Uint64Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Uint64Builder : encoding/json.Unmarshaler
func NewUint64Builder(mem memory.Allocator) *Uint64Builder
(*Uint64DictionaryBuilder) Append(v uint64) error
(*Uint64DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Uint64DictionaryBuilder) AppendEmptyValue()
(*Uint64DictionaryBuilder) AppendEmptyValues(n int)
(*Uint64DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Uint64DictionaryBuilder) AppendNull()
(*Uint64DictionaryBuilder) AppendNulls(n int)
(*Uint64DictionaryBuilder) AppendValueFromString(s string) error
(*Uint64DictionaryBuilder) Cap() int
(*Uint64DictionaryBuilder) DictionarySize() int
(*Uint64DictionaryBuilder) IndexBuilder() IndexBuilder
(*Uint64DictionaryBuilder) InsertDictValues(arr arrValues[uint64]) (err error)
(*Uint64DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Uint64DictionaryBuilder) NewArray() arrow.Array
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)
(*Uint64DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Uint64DictionaryBuilder) Release()
(*Uint64DictionaryBuilder) Reserve(n int)
(*Uint64DictionaryBuilder) ResetFull()
(*Uint64DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Uint64DictionaryBuilder) SetNull(i int)
(*Uint64DictionaryBuilder) Type() arrow.DataType
(*Uint64DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Uint64DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Uint64DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Uint64DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Uint64DictionaryBuilder : Builder
*Uint64DictionaryBuilder : DictionaryBuilder
*Uint64DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Uint64DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Uint64DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Uint64DictionaryBuilder : encoding/json.Unmarshaler
(*Uint8) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
(*Uint8) GetOneForMarshal(i int) any
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
(*Uint8) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
(*Uint8) Offset() int
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.
(*Uint8) Reset(data *Data)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Uint8) String() string
(*Uint8) Uint8Values() []uint8
(*Uint8) Value(i int) uint8
(*Uint8) ValueStr(i int) string
(*Uint8) Values() []uint8
*Uint8 : github.com/apache/arrow-go/v18/arrow.Array[T]
*Uint8 : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Uint8 : github.com/goccy/go-json.Marshaler
*Uint8 : encoding/json.Marshaler
*Uint8 : expvar.Var
*Uint8 : fmt.Stringer
func NewUint8Data(data arrow.ArrayData) *Uint8
func (*Uint8Builder).NewUint8Array() (a *Uint8)
(*Uint8Builder) Append(v uint8)
(*Uint8Builder) AppendEmptyValue()
(*Uint8Builder) AppendEmptyValues(n int)
(*Uint8Builder) AppendNull()
(*Uint8Builder) AppendNulls(n int)
(*Uint8Builder) AppendValueFromString(s string) error
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.
Cap returns the total number of elements that can be stored without allocating additional memory.
(*Uint8Builder) IsNull(i int) bool
Len returns the number of elements in the array builder.
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.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
When the reference count goes to zero, the memory is freed.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Uint8Builder) SetNull(i int)
(*Uint8Builder) Type() arrow.DataType
(*Uint8Builder) Unmarshal(dec *json.Decoder) error
(*Uint8Builder) UnmarshalJSON(data []byte) error
(*Uint8Builder) UnmarshalOne(dec *json.Decoder) error
(*Uint8Builder) UnsafeAppend(v uint8)
(*Uint8Builder) UnsafeAppendBoolToBitmap(isValid bool)
(*Uint8Builder) Value(i int) uint8
*Uint8Builder : Builder
*Uint8Builder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Uint8Builder : github.com/goccy/go-json.Unmarshaler
*Uint8Builder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Uint8Builder : encoding/json.Unmarshaler
func NewUint8Builder(mem memory.Allocator) *Uint8Builder
(*Uint8DictionaryBuilder) Append(v uint8) error
(*Uint8DictionaryBuilder) AppendArray(arr arrow.Array) error
(*Uint8DictionaryBuilder) AppendEmptyValue()
(*Uint8DictionaryBuilder) AppendEmptyValues(n int)
(*Uint8DictionaryBuilder) AppendIndices(indices []int, valid []bool)
(*Uint8DictionaryBuilder) AppendNull()
(*Uint8DictionaryBuilder) AppendNulls(n int)
(*Uint8DictionaryBuilder) AppendValueFromString(s string) error
(*Uint8DictionaryBuilder) Cap() int
(*Uint8DictionaryBuilder) DictionarySize() int
(*Uint8DictionaryBuilder) IndexBuilder() IndexBuilder
(*Uint8DictionaryBuilder) InsertDictValues(arr arrValues[uint8]) (err error)
(*Uint8DictionaryBuilder) IsNull(i int) bool
Len returns the number of elements in the array builder.
(*Uint8DictionaryBuilder) NewArray() arrow.Array
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)
(*Uint8DictionaryBuilder) NewDictionaryArray() *Dictionary
NullN returns the number of null values in the array builder.
(*Uint8DictionaryBuilder) Release()
(*Uint8DictionaryBuilder) Reserve(n int)
(*Uint8DictionaryBuilder) ResetFull()
(*Uint8DictionaryBuilder) Resize(n int)
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
(*Uint8DictionaryBuilder) SetNull(i int)
(*Uint8DictionaryBuilder) Type() arrow.DataType
(*Uint8DictionaryBuilder) Unmarshal(dec *json.Decoder) error
(*Uint8DictionaryBuilder) UnmarshalJSON(data []byte) error
(*Uint8DictionaryBuilder) UnmarshalOne(dec *json.Decoder) error
(*Uint8DictionaryBuilder) UnsafeAppendBoolToBitmap(isValid bool)
*Uint8DictionaryBuilder : Builder
*Uint8DictionaryBuilder : DictionaryBuilder
*Uint8DictionaryBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
*Uint8DictionaryBuilder : github.com/goccy/go-json.Unmarshaler
*Uint8DictionaryBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
*Uint8DictionaryBuilder : encoding/json.Unmarshaler
Union is a convenience interface to encompass both Sparse and Dense
union array types.
ChildID returns the index of the physical child containing the value
at the requested index. Equivalent to:
arr.UnionType().ChildIDs()[arr.RawTypeCodes()[i+arr.Data().Offset()]]
( Union) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
Field returns the requested child array for this union. Returns nil if a
nonexistent position is passed in.
The appropriate child for an index can be retrieved with Field(ChildID(index))
Get single value to be marshalled with `json.Marshal`
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
( Union) MarshalJSON() ([]byte, error)
Mode returns the union mode of the underlying Array, either arrow.SparseMode
or arrow.DenseMode.
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
NumFields returns the number of child fields in this union.
Equivalent to len(UnionType().Fields())
RawTypeCodes returns a slice of UnionTypeCodes properly accounting for
any slice offset.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( Union) String() string
TypeCode returns the logical type code of the value at the requested index
TypeCodes returns the type id buffer for the union Array, equivalent to
Data().Buffers()[1]. Note: This will not account for any slice offset.
UnionType is a convenience function to retrieve the properly typed UnionType
instead of having to call DataType() and manually assert the type.
Validate returns an error if there are any issues with the lengths
or types of the children arrays mismatching with the Type of the
Union Array. nil is returned if there are no problems.
ValidateFull runs the same checks that Validate() does, but additionally
checks that all childIDs are valid (>= 0 || ==InvalidID) and for
dense unions validates that all offsets are within the bounds of their
respective child.
ValueStr returns the value at index as a string.
*DenseUnion
*SparseUnion
Union : github.com/apache/arrow-go/v18/arrow.Array[T]
Union : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
Union : github.com/goccy/go-json.Marshaler
Union : encoding/json.Marshaler
Union : expvar.Var
Union : fmt.Stringer
UnionBuilder is a convenience interface for building Union arrays of
either Dense or Sparse mode.
Append adds an element to the UnionArray indicating which typecode the
new element should use. This *must* be followed up by an append to the
appropriate child builder.
AppendChild allows constructing the union type on the fly by making new
new array builder available to the union builder. The type code (index)
of the new child is returned, which should be passed to the Append method
when adding a new element to the union array.
AppendEmptyValue adds a new zero value of the appropriate type
AppendEmptyValues adds new n zero values of the appropriate type
AppendNull adds a new null value to the array being built.
AppendNulls adds new n null values to the array being built.
AppendValueFromString adds a new value from a string. Inverse of array.ValueStr(i int) string
Cap returns the total number of elements that can be stored
without allocating additional memory.
Child returns the builder for the requested child index.
If an invalid index is requested (e.g. <0 or >len(children))
then this will panic.
IsNull returns if a previously appended value at a given index is null or not.
Len returns the number of elements in the array builder.
Mode returns what kind of Union is being built, either arrow.SparseMode
or arrow.DenseMode
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
SetNull sets the value at index i to null.
Type returns the datatype that this is building
( UnionBuilder) Unmarshal(*json.Decoder) error
( UnionBuilder) UnmarshalJSON([]byte) error
( UnionBuilder) UnmarshalOne(*json.Decoder) error
( UnionBuilder) UnsafeAppendBoolToBitmap(bool)
*DenseUnionBuilder
*SparseUnionBuilder
UnionBuilder : Builder
UnionBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
UnionBuilder : github.com/goccy/go-json.Unmarshaler
UnionBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
UnionBuilder : encoding/json.Unmarshaler
( VarLenListLike) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
Get single value to be marshalled with `json.Marshal`
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
( VarLenListLike) ListValues() arrow.Array
( VarLenListLike) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( VarLenListLike) String() string
( VarLenListLike) ValueOffsets(i int) (start, end int64)
ValueStr returns the value at index as a string.
*FixedSizeList
*LargeList
*LargeListView
*List
ListLike (interface)
*ListView
*Map
VarLenListLike : ListLike
VarLenListLike : github.com/apache/arrow-go/v18/arrow.Array[T]
VarLenListLike : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
VarLenListLike : github.com/goccy/go-json.Marshaler
VarLenListLike : encoding/json.Marshaler
VarLenListLike : expvar.Var
VarLenListLike : fmt.Stringer
func RangeOfValuesUsed(input VarLenListLike) (int, int)
( VarLenListLikeBuilder) Append(bool)
AppendEmptyValue adds a new zero value of the appropriate type
AppendEmptyValues adds new n zero values of the appropriate type
AppendNull adds a new null value to the array being built.
AppendNulls adds new n null values to the array being built.
AppendValueFromString adds a new value from a string. Inverse of array.ValueStr(i int) string
( VarLenListLikeBuilder) AppendWithSize(bool, int)
Cap returns the total number of elements that can be stored
without allocating additional memory.
IsNull returns if a previously appended value at a given index is null or not.
Len returns the number of elements in the array builder.
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.
NullN returns the number of null values in the array builder.
Release decreases the reference count by 1.
Reserve ensures there is enough space for appending n elements
by checking the capacity and calling Resize if necessary.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
SetNull sets the value at index i to null.
Type returns the datatype that this is building
( VarLenListLikeBuilder) Unmarshal(*json.Decoder) error
( VarLenListLikeBuilder) UnmarshalJSON([]byte) error
( VarLenListLikeBuilder) UnmarshalOne(*json.Decoder) error
( VarLenListLikeBuilder) UnsafeAppendBoolToBitmap(bool)
( VarLenListLikeBuilder) ValueBuilder() Builder
*FixedSizeListBuilder
*LargeListBuilder
*LargeListViewBuilder
*ListBuilder
*ListViewBuilder
*MapBuilder
VarLenListLikeBuilder : Builder
VarLenListLikeBuilder : ListLikeBuilder
VarLenListLikeBuilder : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
VarLenListLikeBuilder : github.com/goccy/go-json.Unmarshaler
VarLenListLikeBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ColumnBuilder
VarLenListLikeBuilder : github.com/polarsignals/frostdb/pqarrow/builder.ListLikeBuilder
VarLenListLikeBuilder : encoding/json.Unmarshaler
( ViewLike) Data() arrow.ArrayData
DataType returns the type metadata for this instance.
Get single value to be marshalled with `json.Marshal`
IsNull returns true if value at index is null.
NOTE: IsNull will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
IsValid returns true if value at index is not null.
NOTE: IsValid will panic if NullBitmapBytes is not empty and 0 > i ≥ Len.
Len returns the number of elements in the array.
( ViewLike) MarshalJSON() ([]byte, error)
NullBitmapBytes returns a byte slice of the validity bitmap.
NullN returns the number of null values in the array.
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.
Retain increases the reference count by 1.
Retain may be called simultaneously from multiple goroutines.
( ViewLike) String() string
( ViewLike) ValueHeader(int) *arrow.ViewHeader
ValueStr returns the value at index as a string.
*BinaryView
*StringView
ViewLike : github.com/apache/arrow-go/v18/arrow.Array[T]
ViewLike : github.com/apache/arrow-go/v18/arrow/scalar.Releasable
ViewLike : github.com/goccy/go-json.Marshaler
ViewLike : encoding/json.Marshaler
ViewLike : expvar.Var
ViewLike : fmt.Stringer
Package-Level Functions (total 177)
ApproxEqual reports whether the two provided arrays are approximately equal.
For non-floating point arrays, it is equivalent to Equal.
ChunkedApproxEqual reports whether two chunked arrays are approximately equal regardless of their chunkings
for non-floating point arrays, this is equivalent to ChunkedEqual
ChunkedEqual reports whether two chunked arrays are equal regardless of their chunkings
func ChunkedFromJSON(mem memory.Allocator, dt arrow.DataType, chunkStrs []string, opts ...FromJSONOption) (*arrow.Chunked, 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(mem memory.Allocator, dt *arrow.DictionaryType, indicesJSON, dictJSON string) (arrow.Array, error)
Diff compares two arrays, returning an edit script which expresses the difference
between them. The edit script can be applied to the base array to produce the target.
'base' is a baseline for comparison.
'target' is an array of identical type to base whose elements differ from base's.
Equal reports whether the two provided arrays are equal.
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 GetDictArrayData(mem memory.Allocator, valueType arrow.DataType, memoTable hashing.MemoTable, startOffset int) (*Data, error) func IsTrivialTransposition(transposeMap []int32) bool
IterFromReader converts a RecordReader interface into an iterator that
you can use range on. The semantics are still important, if a record
that is returned is desired to be utilized beyond the scope of an iteration
then Retain must be called on it.
MakeArrayOfNull creates an array of size length which is all null of the given data type.
MakeFromData constructs a strongly-typed array instance from generic Data.
NewBinaryBuilder can be used for any of the variable length binary types,
Binary, LargeBinary, String, LargeString by passing the appropriate data type
NewBinaryData constructs a new Binary array from data.
NewBinaryDictionaryUnifier constructs and returns a new dictionary unifier for dictionaries
of binary values, using the provided allocator for allocating the unified dictionary
and the memotable used for building it.
func NewBinaryViewBuilder(mem memory.Allocator) *BinaryViewBuilder func NewBinaryViewData(data arrow.ArrayData) *BinaryView
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 NewBooleanBuilder(mem memory.Allocator) *BooleanBuilder func NewBooleanData(data arrow.ArrayData) *Boolean
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.
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.
NewData creates a new Data.
NewDataWithDictionary creates a new data object, but also sets the provided dictionary into the data if it's not nil
func NewDate32Builder(mem memory.Allocator) *Date32Builder func NewDate32Data(data arrow.ArrayData) *Date32 func NewDate64Builder(mem memory.Allocator) *Date64Builder func NewDate64Data(data arrow.ArrayData) *Date64 func NewDayTimeIntervalData(data arrow.ArrayData) *DayTimeInterval func NewDecimal128Builder(mem memory.Allocator, dtype *arrow.Decimal128Type) *Decimal128Builder func NewDecimal128Data(data arrow.ArrayData) *Decimal128 func NewDecimal256Builder(mem memory.Allocator, dtype *arrow.Decimal256Type) *Decimal256Builder func NewDecimal256Data(data arrow.ArrayData) *Decimal256 func NewDecimal32Builder(mem memory.Allocator, dtype *arrow.Decimal32Type) *Decimal32Builder func NewDecimal32Data(data arrow.ArrayData) *Decimal32 func NewDecimal64Builder(mem memory.Allocator, dtype *arrow.Decimal64Type) *Decimal64Builder func NewDecimal64Data(data arrow.ArrayData) *Decimal64
NewDenseUnion constructs a union array using the given type, length, list of
children and buffers of typeIDs and offsets, with the given array offset.
NewDenseUnionBuilder constructs a new DenseUnionBuilder with the provided
children and type codes. Builders will be constructed for each child
using the fields in typ
NewDenseUnionWithBuilders returns a new DenseUnionBuilder using the
provided type and builders.
NewDenseUnionData constructs a DenseUnion array from the given ArrayData object.
NewDenseUnionFromArrays constructs a new DenseUnion array with the provided
values.
typeIDs *must* be an INT8 array with no nulls
offsets *must* be an INT32 array with no nulls
len(codes) *must* be either 0 or equal to len(children). If len(codes) is 0,
the type codes used will be sequentially numeric starting at 0.
NewDenseUnionFromArraysWithFieldCodes combines the other constructors
for constructing a new DenseUnion array with the provided field names
and type codes, along with children and type ids.
All the requirements mentioned in NewDenseUnionFromArrays and
NewDenseUnionFromArraysWithFields apply.
NewDenseUnionFromArrayWithFields constructs a new DenseUnion array like
NewDenseUnionFromArrays, but allows specifying the field names. Type codes
will be auto-generated sequentially starting at 0.
typeIDs *must* be an INT8 array with no nulls.
offsets *must* be an INT32 array with no nulls.
len(fields) *must* either be 0 or equal to len(children). If len(fields) is 0,
then the fields will be named sequentially starting at "0".
NewDictionaryArray constructs a dictionary array with the provided indices
and dictionary using the given type.
func NewDictionaryBuilder(mem memory.Allocator, dt *arrow.DictionaryType) 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.
NewDictionaryData creates a strongly typed Dictionary array from
an ArrayData object with a datatype of arrow.Dictionary and a dictionary
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 Parameters:
T: arrow.ValueType
NewDictWrapper creates a simple wrapper around a Dictionary array that provides
a Value method which will use the underlying dictionary to return the value
at the given index. This simplifies the interaction of a dictionary array to
provide a typed interface as if it were a non-dictionary array.
func NewDurationBuilder(mem memory.Allocator, dtype *arrow.DurationType) *DurationBuilder func NewDurationData(data arrow.ArrayData) *Duration
NewEmptyDenseUnionBuilder is a helper to construct a DenseUnionBuilder
without having to predefine the union types. It creates a builder with no
children and AppendChild will have to be called before appending any
elements to this builder.
NewEmptySparseUnionBuilder is a helper to construct a SparseUnionBuilder
without having to predefine the union types. It creates a builder with no
children and AppendChild will have to be called before appending any
elements to this builder.
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.
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.
NewExtensionData expects a data with a datatype of arrow.ExtensionType and
underlying data built for the storage array.
func NewFixedSizeBinaryBuilder(mem memory.Allocator, dtype *arrow.FixedSizeBinaryType) *FixedSizeBinaryBuilder
NewFixedSizeBinaryData constructs a new fixed-size binary array from data.
NewFixedSizeListBuilder returns a builder, using the provided memory allocator.
The created list builder will create a list whose elements will be of type etype.
NewFixedSizeListBuilderWithField returns a builder similarly to
NewFixedSizeListBuilder, but it accepts a child rather than just a datatype
to ensure nullability context is preserved.
NewFixedSizeListData returns a new List array value, from data.
func NewFloat16Builder(mem memory.Allocator) *Float16Builder func NewFloat16Data(data arrow.ArrayData) *Float16 func NewFloat32Builder(mem memory.Allocator) *Float32Builder func NewFloat32Data(data arrow.ArrayData) *Float32 func NewFloat64Builder(mem memory.Allocator) *Float64Builder func NewFloat64Data(data arrow.ArrayData) *Float64 func NewInt16Builder(mem memory.Allocator) *Int16Builder func NewInt16Data(data arrow.ArrayData) *Int16 func NewInt32Builder(mem memory.Allocator) *Int32Builder func NewInt32Data(data arrow.ArrayData) *Int32 func NewInt64Builder(mem memory.Allocator) *Int64Builder func NewInt64Data(data arrow.ArrayData) *Int64 func NewInt8Builder(mem memory.Allocator) *Int8Builder func NewInt8Data(data arrow.ArrayData) *Int8 func NewIntervalData(data arrow.ArrayData) arrow.Array
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 NewLargeBinaryData(data arrow.ArrayData) *LargeBinary
NewLargeListBuilder returns a builder, using the provided memory allocator.
The created list builder will create a list whose elements will be of type etype.
NewLargeListBuilderWithField takes a field rather than just an element type
to allow for more customization of the final type of the LargeList Array
NewLargeListData returns a new LargeList array value, from data.
NewLargeListViewBuilder returns a builder, using the provided memory allocator.
The created list-view builder will create a list whose elements will be of type etype.
NewLargeListViewBuilderWithField takes a field rather than just an element type
to allow for more customization of the final type of the LargeListView Array
NewLargeListViewData returns a new LargeListView array value, from data.
NewStringBuilder creates a new StringBuilder.
NewStringData constructs a new String array from data.
NewListBuilder returns a builder, using the provided memory allocator.
The created list builder will create a list whose elements will be of type etype.
NewListBuilderWithField takes a field to use for the child rather than just
a datatype to allow for more customization.
NewListData returns a new List array value, from data.
NewListViewBuilder returns a builder, using the provided memory allocator.
The created list-view builder will create a list whose elements will be
of type etype.
NewListViewBuilderWithField takes a field to use for the child rather than just
a datatype to allow for more customization.
func NewListViewData(data arrow.ArrayData) *ListView
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 NewMapBuilderWithType(mem memory.Allocator, dt *arrow.MapType) *MapBuilder
NewMapData returns a new Map array value, from data
func NewMonthIntervalData(data arrow.ArrayData) *MonthInterval
NewNull returns a new Null array value of size n.
NewNullBuilder returns a builder, using the provided memory allocator.
NewNullData returns a new Null array value, from data.
Deprecated: Use [NewRecordBatch] instead.
NewRecordBatch returns a basic, non-lazy in-memory record batch.
NewRecordBatch panics if the columns and schema are inconsistent.
NewRecordBatch panics if rows is larger than the height of the columns.
NewRecordBuilder returns a builder, using the provided memory allocator and a schema.
NewRecordReader returns a simple iterator over the given slice of records.
func NewRunEndEncodedArray(runEnds, values arrow.Array, logicalLength, offset int) *RunEndEncoded func NewRunEndEncodedBuilder(mem memory.Allocator, runEnds, encoded arrow.DataType) *RunEndEncodedBuilder func NewRunEndEncodedData(data arrow.ArrayData) *RunEndEncoded
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.
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.
NewSparseUnion constructs a union array using the given type, length, list of
children and buffer of typeIDs with the given offset.
NewSparseUnionBuilder constructs a new SparseUnionBuilder with the provided
children and type codes. Builders will be constructed for each child
using the fields in typ
NewSparseUnionWithBuilders returns a new SparseUnionBuilder using the
provided type and builders.
NewSparseUnionData constructs a SparseUnion array from the given ArrayData object.
NewSparseUnionFromArrays constructs a new SparseUnion array with the provided
values.
typeIDs *must* be an INT8 array with no nulls
len(codes) *must* be either 0 or equal to len(children). If len(codes) is 0,
the type codes used will be sequentially numeric starting at 0.
NewSparseUnionFromArraysWithFieldCodes combines the other constructors
for constructing a new SparseUnion array with the provided field names
and type codes, along with children and type ids.
All the requirements mentioned in NewSparseUnionFromArrays and
NewSparseUnionFromArraysWithFields apply.
NewSparseUnionFromArrayWithFields constructs a new SparseUnion array like
NewSparseUnionFromArrays, but allows specifying the field names. Type codes
will be auto-generated sequentially starting at 0.
typeIDs *must* be an INT8 array with no nulls.
len(fields) *must* either be 0 or equal to len(children). If len(fields) is 0,
then the fields will be named sequentially starting at "0".
NewStringBuilder creates a new StringBuilder.
NewStringData constructs a new String array from data.
func NewStringViewBuilder(mem memory.Allocator) *StringViewBuilder func NewStringViewData(data arrow.ArrayData) *StringView
NewStructArray constructs a new Struct Array out of the columns passed
in and the field names. The length of all cols must be the same and
there should be the same number of columns as names.
NewStructArrayWithFields builds a new Struct Array using the passed columns
and provided fields. As opposed to NewStructArray, this allows you to provide
the full fields to utilize for the struct column instead of just the names.
NewStructArrayWithFieldsAndNulls is like NewStructArrayWithFields as a convenience function,
but also takes in a null bitmap, the number of nulls, and an optional offset
to use for creating the Struct Array.
NewStructArrayWithNulls is like NewStructArray as a convenience function,
but also takes in a null bitmap, the number of nulls, and an optional offset
to use for creating the Struct Array.
NewStructBuilder returns a builder, using the provided memory allocator.
NewStructData returns a new Struct array value from data.
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.
NewTableFromRecords returns a new basic, non-lazy in-memory table.
NewTableFromRecords panics if the records and schema are inconsistent.
NewTableFromSlice is a convenience function to create a table from a slice
of slices of arrow.Array.
Like other NewTable functions this can panic if:
- len(schema.Fields) != len(data)
- the total length of each column's array slice (ie: number of rows
in the column) aren't the same for all columns.
NewTableReader returns a new TableReader to iterate over the (possibly chunked) Table.
if chunkSize is <= 0, the biggest possible chunk will be selected.
func NewTime32Builder(mem memory.Allocator, dtype *arrow.Time32Type) *Time32Builder func NewTime32Data(data arrow.ArrayData) *Time32 func NewTime64Builder(mem memory.Allocator, dtype *arrow.Time64Type) *Time64Builder func NewTime64Data(data arrow.ArrayData) *Time64 func NewTimestampBuilder(mem memory.Allocator, dtype *arrow.TimestampType) *TimestampBuilder
NewTimestampData creates a new Timestamp from Data.
func NewUint16Builder(mem memory.Allocator) *Uint16Builder func NewUint16Data(data arrow.ArrayData) *Uint16 func NewUint32Builder(mem memory.Allocator) *Uint32Builder func NewUint32Data(data arrow.ArrayData) *Uint32 func NewUint64Builder(mem memory.Allocator) *Uint64Builder func NewUint64Data(data arrow.ArrayData) *Uint64 func NewUint8Builder(mem memory.Allocator) *Uint8Builder func NewUint8Data(data arrow.ArrayData) *Uint8
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.
Returns the smallest contiguous range of values of the child array that are
referenced by all the list values in the input array.
ReaderFromIter wraps a go iterator for arrow.RecordBatch + error into a RecordReader
interface object for ease of use.
RecordApproxEqual reports whether the two provided records are approximately equal.
For non-floating point columns, it is equivalent to RecordEqual.
RecordEqual reports whether the two provided records are equal.
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.
See https://github.com/apache/arrow-go/issues/448 for more details on
why this isn't a simple wrapper around FromJSON.
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.
RecordToJSON writes out the given record following the format of each row is a single object
on a single line of the output.
RecordToStructArray constructs a struct array from the columns of the record batch
by referencing them, zero-copy.
SliceApproxEqual reports whether slices left[lbeg:lend] and right[rbeg:rend] are approximately equal.
SliceEqual reports whether slices left[lbeg:lend] and right[rbeg:rend] are equal.
TableEqual returns if the two tables have the approximately equal data in the same schema
TableEqual returns if the two tables have the same data in the same schema
func TableFromJSON(mem memory.Allocator, sc *arrow.Schema, recJSON []string, opt ...FromJSONOption) (arrow.Table, error) func TransposeDictIndices(mem memory.Allocator, data arrow.ArrayData, inType, outType arrow.DataType, dict arrow.ArrayData, transposeMap []int32) (arrow.ArrayData, 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.
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.
WithAbsTolerance configures the comparison functions so that 2 floating point values
v1 and v2 are considered equal if |v1-v2| <= atol.
WithAllocator specifies the allocator to use for creating the record batches,
if it is not called, then memory.DefaultAllocator will be used.
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.
func WithMultipleDocs() FromJSONOption
WithNaNsEqual configures the comparison functions so that NaNs are considered equal.
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
WithUnorderedMapKeys configures the comparison functions so that Map with different entries order are considered equal.
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.
Package-Level Constants (total 2)
NullValueStr represents a null value in arrow.Array.ValueStr and in Builder.AppendValueFromString.
It should be returned from the arrow.Array.ValueStr implementations.
Using it as the value in Builder.AppendValueFromString should be equivalent to Builder.AppendNull.
UnknownNullCount specifies the NullN should be calculated from the null bitmap buffer.
 |
The pages are generated with Golds v0.8.2. (GOOS=linux GOARCH=amd64) Golds is a Go 101 project developed by Tapir Liu. PR and bug reports are welcome and can be submitted to the issue list. Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds. |