builder

package
v0.0.0-...-cafc5b9 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BinaryBuilder 

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

BinaryBuilder is a wrapper around the arrow BinaryBuilder.

func (*BinaryBuilder) Append 

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

Append appends a value to the underlying builder and updates the transform node if the builder is nil.

func (*BinaryBuilder) AppendNonNil 

func (b *BinaryBuilder) AppendNonNil(value []byte)

AppendNonNil appends a value to the underlying builder and updates the transform node if the builder is nil. Note: nil values are not appended to the builder.

func (*BinaryBuilder) AppendNull 

func (b *BinaryBuilder) AppendNull()

AppendNull appends a null value to the underlying builder. If the builder is nil we do nothing as we have no information about the presence of this field in the data.

type BooleanBuilder 

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

MapBuilder is a wrapper around the arrow MapBuilder.

func (*BooleanBuilder) Append 

func (b *BooleanBuilder) Append(value bool)

Append appends a value to the underlying builder and updates the transform node if the builder is nil.

func (*BooleanBuilder) AppendNonFalse 

func (b *BooleanBuilder) AppendNonFalse(value bool)

AppendNonFalse appends a value to the underlying builder and updates the transform node if the builder is nil. Note: false values are not appended to the builder.

func (*BooleanBuilder) AppendNull 

func (b *BooleanBuilder) AppendNull()

AppendNull appends a null value to the underlying builder. If the builder is nil we do nothing as we have no information about the presence of this field in the data.

type DurationBuilder 

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

DurationBuilder is a wrapper around the arrow DurationBuilder.

func (*DurationBuilder) Append 

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

Append appends a value to the underlying builder and updates the transform node if the builder is nil.

func (*DurationBuilder) AppendNull 

func (b *DurationBuilder) AppendNull()

AppendNull appends a null value to the underlying builder. If the builder is nil we do nothing as we have no information about the presence of this field in the data.

type FixedSizeBinaryBuilder 

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

FixedSizeBinaryBuilder is a wrapper around the arrow FixedSizeBinaryBuilder.

func (*FixedSizeBinaryBuilder) Append 

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

Append appends a value to the underlying builder and updates the transform node if the builder is nil.

func (*FixedSizeBinaryBuilder) AppendNull 

func (b *FixedSizeBinaryBuilder) AppendNull()

AppendNull appends a null value to the underlying builder. If the builder is nil we do nothing as we have no information about the presence of this field in the data.

type Float64Builder 

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

Float64Builder is a wrapper around the arrow array builder for float64.

func (*Float64Builder) Append 

func (b *Float64Builder) Append(value float64)

Append adds a value to the underlying builder or updates the transform node if the builder is nil.

func (*Float64Builder) AppendNonZero 

func (b *Float64Builder) AppendNonZero(value float64)

AppendNonZero adds a value to the underlying builder or updates the transform node if the builder is nil. Note: 0 values are not appended to the builder.

func (*Float64Builder) AppendNull 

func (b *Float64Builder) AppendNull()

AppendNull adds a null value to the underlying builder. If the builder is nil we do nothing as we have no information about the presence of this field in the data.

type Int32Builder 

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

Int32Builder is a wrapper around the arrow Int32Builder.

func (*Int32Builder) Append 

func (b *Int32Builder) Append(value int32)

Append appends a value to the underlying builder and updates the transform node if the builder is nil.

func (*Int32Builder) AppendNonZero 

func (b *Int32Builder) AppendNonZero(value int32)

AppendNonZero appends a value to the underlying builder and updates the transform node if the builder is nil. Note: 0 values are not appended to the builder.

func (*Int32Builder) AppendNull 

func (b *Int32Builder) AppendNull()

AppendNull appends a null value to the underlying builder. If the builder is nil we do nothing as we have no information about the presence of this field in the data.

type Int64Builder 

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

Int64Builder is a wrapper around the arrow Int64Builder.

func (*Int64Builder) Append 

func (b *Int64Builder) Append(value int64)

Append appends a value to the underlying builder and updates the transform node if the builder is nil.

func (*Int64Builder) AppendNonZero 

func (b *Int64Builder) AppendNonZero(value int64)

AppendNonZero appends a value to the underlying builder and updates the transform node if the builder is nil. Note: 0 value are not appended.

func (*Int64Builder) AppendNull 

func (b *Int64Builder) AppendNull()

AppendNull appends a null value to the underlying builder. If the builder is nil we do nothing as we have no information about the presence of this field in the data.

type ListBuilder 

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

ListBuilder is a wrapper around the arrow.ListBuilder.

func (*ListBuilder) Append 

func (lb *ListBuilder) Append(itemCount int, itemsAppender func() error) error

func (*ListBuilder) AppendNull 

func (lb *ListBuilder) AppendNull()

AppendNull adds a null list to the underlying builder. If the builder is nil we do nothing as we have no information about the presence of this field in the data.

func (*ListBuilder) Float64Builder 

func (lb *ListBuilder) Float64Builder() *Float64Builder

func (*ListBuilder) Reserve 

func (lb *ListBuilder) Reserve(numItems int)

Reserve adds a list to the underlying builder or updates the transform node if the builder is nil (and if the append parameter is true). The list is initialized with the given number of items.

func (*ListBuilder) SparseUnionBuilder 

func (lb *ListBuilder) SparseUnionBuilder() *SparseUnionBuilder

SparseUnionBuilder returns a SparseUnionBuilder initialized with the underlying arrow array builder representing a list of elements of sparse union type.

func (*ListBuilder) StructBuilder 

func (lb *ListBuilder) StructBuilder() *StructBuilder

func (*ListBuilder) Uint64Builder 

func (lb *ListBuilder) Uint64Builder() *Uint64Builder

type MapBuilder 

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

MapBuilder is a wrapper around the arrow MapBuilder.

func (*MapBuilder) Append 

func (b *MapBuilder) Append(mapLen int, mapAppender func() error) error

func (*MapBuilder) AppendNull 

func (b *MapBuilder) AppendNull()

AppendNull appends a null value to the underlying builder. If the builder is nil we do nothing as we have no information about the presence of this field in the data.

func (*MapBuilder) ItemBinaryBuilder 

func (b *MapBuilder) ItemBinaryBuilder() *BinaryBuilder

func (*MapBuilder) ItemBooleanBuilder 

func (b *MapBuilder) ItemBooleanBuilder() *BooleanBuilder

func (*MapBuilder) ItemFixedSizeBinaryBuilder 

func (b *MapBuilder) ItemFixedSizeBinaryBuilder() *FixedSizeBinaryBuilder

func (*MapBuilder) ItemFloat64Builder 

func (b *MapBuilder) ItemFloat64Builder() *Float64Builder

func (*MapBuilder) ItemInt32Builder 

func (b *MapBuilder) ItemInt32Builder() *Int32Builder

func (*MapBuilder) ItemInt64Builder 

func (b *MapBuilder) ItemInt64Builder() *Int64Builder

func (*MapBuilder) ItemListBuilder 

func (b *MapBuilder) ItemListBuilder() *ListBuilder

func (*MapBuilder) ItemMapBuilder 

func (b *MapBuilder) ItemMapBuilder() *MapBuilder

func (*MapBuilder) ItemSparseUnionBuilder 

func (b *MapBuilder) ItemSparseUnionBuilder() *SparseUnionBuilder

func (*MapBuilder) ItemStringBuilder 

func (b *MapBuilder) ItemStringBuilder() *StringBuilder

func (*MapBuilder) ItemStructBuilder 

func (b *MapBuilder) ItemStructBuilder() *StructBuilder

func (*MapBuilder) ItemTimestampBuilder 

func (b *MapBuilder) ItemTimestampBuilder() *TimestampBuilder

func (*MapBuilder) ItemUint32Builder 

func (b *MapBuilder) ItemUint32Builder() *Uint32Builder

func (*MapBuilder) ItemUint64Builder 

func (b *MapBuilder) ItemUint64Builder() *Uint64Builder

func (*MapBuilder) ItemUint8Builder 

func (b *MapBuilder) ItemUint8Builder() *Uint8Builder

func (*MapBuilder) KeyBinaryBuilder 

func (b *MapBuilder) KeyBinaryBuilder() *BinaryBuilder

func (*MapBuilder) KeyBooleanBuilder 

func (b *MapBuilder) KeyBooleanBuilder() *BooleanBuilder

func (*MapBuilder) KeyFixedSizeBinaryBuilder 

func (b *MapBuilder) KeyFixedSizeBinaryBuilder() *FixedSizeBinaryBuilder

func (*MapBuilder) KeyFloat64Builder 

func (b *MapBuilder) KeyFloat64Builder() *Float64Builder

func (*MapBuilder) KeyInt32Builder 

func (b *MapBuilder) KeyInt32Builder() *Int32Builder

func (*MapBuilder) KeyInt64Builder 

func (b *MapBuilder) KeyInt64Builder() *Int64Builder

func (*MapBuilder) KeyListBuilder 

func (b *MapBuilder) KeyListBuilder() *ListBuilder

func (*MapBuilder) KeyMapBuilder 

func (b *MapBuilder) KeyMapBuilder() *MapBuilder

func (*MapBuilder) KeySparseUnionBuilder 

func (b *MapBuilder) KeySparseUnionBuilder() *SparseUnionBuilder

func (*MapBuilder) KeyStringBuilder 

func (b *MapBuilder) KeyStringBuilder() *StringBuilder

func (*MapBuilder) KeyStructBuilder 

func (b *MapBuilder) KeyStructBuilder() *StructBuilder

func (*MapBuilder) KeyTimestampBuilder 

func (b *MapBuilder) KeyTimestampBuilder() *TimestampBuilder

func (*MapBuilder) KeyUint32Builder 

func (b *MapBuilder) KeyUint32Builder() *Uint32Builder

func (*MapBuilder) KeyUint64Builder 

func (b *MapBuilder) KeyUint64Builder() *Uint64Builder

func (*MapBuilder) NewMapArray 

func (b *MapBuilder) NewMapArray() *array.Map

func (*MapBuilder) Release 

func (b *MapBuilder) Release()

func (*MapBuilder) Reserve 

func (b *MapBuilder) Reserve(numEntries int)

Reserve reserves space for the given number of entries in the map.

type RecordBuilderExt 

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

RecordBuilderExt is a wrapper/decorator around array.RecordBuilder that allows you to request schema updates while building an Arrow record.

This capability allows to automatically handle optional fields and dictionary fields that can directly mutate to their base type if the dictionary index overflows.

func NewRecordBuilderExt 

func NewRecordBuilderExt(
	allocator memory.Allocator,
	protoSchema *arrow.Schema,
	dictConfig *builder.Dictionary,
	stats *stats.ProducerStats,
) *RecordBuilderExt

NewRecordBuilderExt creates a new RecordBuilderExt from the given allocator and a prototype schema.

func (*RecordBuilderExt) BinaryBuilder 

func (rb *RecordBuilderExt) BinaryBuilder(name string) *BinaryBuilder

BinaryBuilder returns a BinaryBuilder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) BooleanBuilder 

func (rb *RecordBuilderExt) BooleanBuilder(name string) *BooleanBuilder

BooleanBuilder returns a BooleanBuilder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) DurationBuilder 

func (rb *RecordBuilderExt) DurationBuilder(name string) *DurationBuilder

DurationBuilder returns a DurationBuilder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) Events 

func (rb *RecordBuilderExt) Events() *events.Events

func (*RecordBuilderExt) FixedSizeBinaryBuilder 

func (rb *RecordBuilderExt) FixedSizeBinaryBuilder(name string) *FixedSizeBinaryBuilder

FixedSizeBinaryBuilder returns a FixedSizeBinaryBuilder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) Float64Builder 

func (rb *RecordBuilderExt) Float64Builder(name string) *Float64Builder

Float64Builder returns a Float64Builder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) Int32Builder 

func (rb *RecordBuilderExt) Int32Builder(name string) *Int32Builder

Int32Builder returns a Int32Builder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) Int64Builder 

func (rb *RecordBuilderExt) Int64Builder(name string) *Int64Builder

Int64Builder returns a Int64Builder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) IsSchemaUpToDate 

func (rb *RecordBuilderExt) IsSchemaUpToDate() bool

func (*RecordBuilderExt) Label 

func (rb *RecordBuilderExt) Label() string

func (*RecordBuilderExt) ListBuilder 

func (rb *RecordBuilderExt) ListBuilder(name string) *ListBuilder

ListBuilder returns a ListBuilder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) MapBuilder 

func (rb *RecordBuilderExt) MapBuilder(name string) *MapBuilder

MapBuilder returns a MapBuilder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) NewRecord 

func (rb *RecordBuilderExt) NewRecord() (arrow.Record, error)

NewRecord returns a new record from the underlying array.RecordBuilder or ErrSchemaNotUpToDate if the schema is not up-to-date.

func (*RecordBuilderExt) RecordBuilder 

func (rb *RecordBuilderExt) RecordBuilder() *array.RecordBuilder

RecordBuilder returns the underlying array.RecordBuilder.

func (*RecordBuilderExt) Release 

func (rb *RecordBuilderExt) Release()

func (*RecordBuilderExt) Reserve 

func (rb *RecordBuilderExt) Reserve(size int)

func (*RecordBuilderExt) Schema 

func (rb *RecordBuilderExt) Schema() *arrow.Schema

func (*RecordBuilderExt) SchemaID 

func (rb *RecordBuilderExt) SchemaID() string

func (*RecordBuilderExt) SchemaUpdateRequestReset 

func (rb *RecordBuilderExt) SchemaUpdateRequestReset()

func (*RecordBuilderExt) SetLabel 

func (rb *RecordBuilderExt) SetLabel(label string)

func (*RecordBuilderExt) ShowSchema 

func (rb *RecordBuilderExt) ShowSchema()

func (*RecordBuilderExt) SparseUnionBuilder 

func (rb *RecordBuilderExt) SparseUnionBuilder(name string) *SparseUnionBuilder

SparseUnionBuilder returns a SparseUnionBuilder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) StringBuilder 

func (rb *RecordBuilderExt) StringBuilder(name string) *StringBuilder

StringBuilder returns a StringBuilder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) StructBuilder 

func (rb *RecordBuilderExt) StructBuilder(name string) *StructBuilder

StructBuilder returns a StructBuilder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) TimestampBuilder 

func (rb *RecordBuilderExt) TimestampBuilder(name string) *TimestampBuilder

TimestampBuilder returns a TimestampBuilder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) Uint16Builder 

func (rb *RecordBuilderExt) Uint16Builder(name string) *Uint16Builder

Uint16Builder returns a Uint16Builder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) Uint16DeltaBuilder 

func (rb *RecordBuilderExt) Uint16DeltaBuilder(name string) *Uint16DeltaBuilder

Uint16DeltaBuilder returns a Uint16DeltaBuilder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) Uint32Builder 

func (rb *RecordBuilderExt) Uint32Builder(name string) *Uint32Builder

Uint32Builder returns a Uint32Builder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) Uint32DeltaBuilder 

func (rb *RecordBuilderExt) Uint32DeltaBuilder(name string) *Uint32DeltaBuilder

Uint32DeltaBuilder returns a Uint32DeltaBuilder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) Uint64Builder 

func (rb *RecordBuilderExt) Uint64Builder(name string) *Uint64Builder

Uint64Builder returns a Uint64Builder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) Uint8Builder 

func (rb *RecordBuilderExt) Uint8Builder(name string) *Uint8Builder

Uint8Builder returns a Uint8Builder wrapper for the field with the given name. If the underlying builder doesn't exist, an empty wrapper is returned, so that the feeding process can continue without panicking. This is useful to handle optional fields.

func (*RecordBuilderExt) UpdateSchema 

func (rb *RecordBuilderExt) UpdateSchema()

UpdateSchema updates the schema based on the pending schema update requests the initial prototype schema.

func (*RecordBuilderExt) VisitDataType 

func (rb *RecordBuilderExt) VisitDataType(builder array.Builder, dt arrow.DataType, dictID string, prefix string)

func (*RecordBuilderExt) VisitField 

func (rb *RecordBuilderExt) VisitField(builder array.Builder, field *arrow.Field, prefix string)

func (*RecordBuilderExt) VisitRecordBuilder 

func (rb *RecordBuilderExt) VisitRecordBuilder(recBuilder *array.RecordBuilder, prefix string)

type SparseUnionBuilder 

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

func NewSparseUnionBuilder 

func NewSparseUnionBuilder(
	protoDataType *arrow.SparseUnionType,
	builder *array.SparseUnionBuilder,
	transformNode *schema.TransformNode,
	updateRequest *update.SchemaUpdateRequest,
) *SparseUnionBuilder

func (*SparseUnionBuilder) Append 

func (sub *SparseUnionBuilder) Append(code int8)

func (*SparseUnionBuilder) AppendNull 

func (sub *SparseUnionBuilder) AppendNull()

func (*SparseUnionBuilder) BinaryBuilder 

func (sub *SparseUnionBuilder) BinaryBuilder(code arrow.UnionTypeCode) *BinaryBuilder

BinaryBuilder returns a builder for the given child code.

func (*SparseUnionBuilder) BooleanBuilder 

func (sub *SparseUnionBuilder) BooleanBuilder(code arrow.UnionTypeCode) *BooleanBuilder

BooleanBuilder returns a builder for the given child code.

func (*SparseUnionBuilder) Float64Builder 

func (sub *SparseUnionBuilder) Float64Builder(code arrow.UnionTypeCode) *Float64Builder

Float64Builder returns a builder for the given child code.

func (*SparseUnionBuilder) Int32Builder 

func (sub *SparseUnionBuilder) Int32Builder(code arrow.UnionTypeCode) *Int32Builder

Int32Builder returns a builder for the given child code.

func (*SparseUnionBuilder) Int64Builder 

func (sub *SparseUnionBuilder) Int64Builder(code arrow.UnionTypeCode) *Int64Builder

Int64Builder returns a builder for the given child code.

func (*SparseUnionBuilder) NewSparseUnionArray 

func (sub *SparseUnionBuilder) NewSparseUnionArray() *array.SparseUnion

func (*SparseUnionBuilder) Release 

func (sub *SparseUnionBuilder) Release()

func (*SparseUnionBuilder) StringBuilder 

func (sub *SparseUnionBuilder) StringBuilder(code arrow.UnionTypeCode) *StringBuilder

StringBuilder returns a builder for the given child code.

func (*SparseUnionBuilder) StructBuilder 

func (sub *SparseUnionBuilder) StructBuilder(code arrow.UnionTypeCode) *StructBuilder

StructBuilder returns a builder for the given child code.

func (*SparseUnionBuilder) Uint32Builder 

func (sub *SparseUnionBuilder) Uint32Builder(code arrow.UnionTypeCode) *Uint32Builder

Uint32Builder returns a builder for the given child code.

func (*SparseUnionBuilder) Uint64Builder 

func (sub *SparseUnionBuilder) Uint64Builder(code arrow.UnionTypeCode) *Uint64Builder

Uint64Builder returns a builder for the given child code.

func (*SparseUnionBuilder) Uint8Builder 

func (sub *SparseUnionBuilder) Uint8Builder(code arrow.UnionTypeCode) *Uint8Builder

Uint8Builder returns a builder for the given child code.

type StringBuilder 

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

func NewStringBuilder 

func NewStringBuilder(builder array.Builder, transformNode *schema.TransformNode, updateRequest *update.SchemaUpdateRequest) *StringBuilder

NewStringBuilder creates a new StringBuilder.

func (*StringBuilder) Append 

func (b *StringBuilder) Append(value string)

func (*StringBuilder) AppendNonEmpty 

func (b *StringBuilder) AppendNonEmpty(value string)

func (*StringBuilder) AppendNull 

func (b *StringBuilder) AppendNull()

type StructBuilder 

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

func (*StructBuilder) Append 

func (sb *StructBuilder) Append(data interface{}, fieldAppenders func() error) (err error)

func (*StructBuilder) AppendNull 

func (sb *StructBuilder) AppendNull()

func (*StructBuilder) BinaryBuilder 

func (sb *StructBuilder) BinaryBuilder(name string) *BinaryBuilder

BinaryBuilder returns a BinaryBuilder for the given field name.

func (*StructBuilder) BooleanBuilder 

func (sb *StructBuilder) BooleanBuilder(name string) *BooleanBuilder

BooleanBuilder returns a BooleanBuilder for the given field name.

func (*StructBuilder) DurationBuilder 

func (sb *StructBuilder) DurationBuilder(name string) *DurationBuilder

DurationBuilder returns a DurationBuilder for the given field name.

func (*StructBuilder) FixedSizeBinaryBuilder 

func (sb *StructBuilder) FixedSizeBinaryBuilder(name string) *FixedSizeBinaryBuilder

FixedSizeBinaryBuilder returns a FixedSizeBinaryBuilder for the given field name.

func (*StructBuilder) Float64Builder 

func (sb *StructBuilder) Float64Builder(name string) *Float64Builder

Float64Builder returns a Float64Builder for the given field name.

func (*StructBuilder) Int32Builder 

func (sb *StructBuilder) Int32Builder(name string) *Int32Builder

Int32Builder returns a Int32Builder for the given field name.

func (*StructBuilder) Int64Builder 

func (sb *StructBuilder) Int64Builder(name string) *Int64Builder

Int64Builder returns a Int64Builder for the given field name.

func (*StructBuilder) ListBuilder 

func (sb *StructBuilder) ListBuilder(name string) *ListBuilder

ListBuilder returns a ListBuilder for the given field name.

func (*StructBuilder) MapBuilder 

func (sb *StructBuilder) MapBuilder(name string) *MapBuilder

MapBuilder returns a MapBuilder for the given field name.

func (*StructBuilder) NewStructArray 

func (sb *StructBuilder) NewStructArray() *array.Struct

func (*StructBuilder) Release 

func (sb *StructBuilder) Release()

func (*StructBuilder) SparseUnionBuilder 

func (sb *StructBuilder) SparseUnionBuilder(name string) *SparseUnionBuilder

SparseUnionBuilder returns a SparseUnionBuilder for the given field name.

func (*StructBuilder) StringBuilder 

func (sb *StructBuilder) StringBuilder(name string) *StringBuilder

StringBuilder returns a StringBuilder for the given field name.

func (*StructBuilder) StructBuilder 

func (sb *StructBuilder) StructBuilder(name string) *StructBuilder

StructBuilder returns a StructBuilder for the given field name.

func (*StructBuilder) TimestampBuilder 

func (sb *StructBuilder) TimestampBuilder(name string) *TimestampBuilder

TimestampBuilder creates a new TimestampBuilder for the given field name.

func (*StructBuilder) Uint16DeltaBuilder 

func (sb *StructBuilder) Uint16DeltaBuilder(name string) *Uint16DeltaBuilder

Uint16DeltaBuilder returns a Uint16DeltaBuilder for the given field name.

func (*StructBuilder) Uint32Builder 

func (sb *StructBuilder) Uint32Builder(name string) *Uint32Builder

Uint32Builder returns a Uint32Builder for the given field name.

func (*StructBuilder) Uint32DeltaBuilder 

func (sb *StructBuilder) Uint32DeltaBuilder(name string) *Uint32DeltaBuilder

Uint32DeltaBuilder returns a Uint32DeltaBuilder for the given field name.

func (*StructBuilder) Uint64Builder 

func (sb *StructBuilder) Uint64Builder(name string) *Uint64Builder

Uint64Builder returns a Uint64Builder for the given field name.

func (*StructBuilder) Uint8Builder 

func (sb *StructBuilder) Uint8Builder(name string) *Uint8Builder

Uint8Builder returns a Uint8Builder for the given field name.

type TimestampBuilder 

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

TimestampBuilder is a wrapper around the arrow TimestampBuilder.

func (*TimestampBuilder) Append 

func (b *TimestampBuilder) Append(value arrow.Timestamp)

Append appends a value to the underlying builder and updates the transform node if the builder is nil.

func (*TimestampBuilder) AppendNull 

func (b *TimestampBuilder) AppendNull()

AppendNull appends a null value to the underlying builder. If the builder is nil we do nothing as we have no information about the presence of this field in the data.

type Uint16Builder 

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

Uint16Builder is a wrapper around the arrow array builder for uint16.

func (*Uint16Builder) Append 

func (b *Uint16Builder) Append(value uint16)

func (*Uint16Builder) AppendNonZero 

func (b *Uint16Builder) AppendNonZero(value uint16)

func (*Uint16Builder) AppendNull 

func (b *Uint16Builder) AppendNull()

type Uint16DeltaBuilder 

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

Uint16DeltaBuilder is a wrapper around the arrow array builder for uint16 with delta encoding.

func NewUint16DeltaBuilder 

func NewUint16DeltaBuilder(b array.Builder, transformNode *schema.TransformNode, updateReq *update.SchemaUpdateRequest) *Uint16DeltaBuilder

NewUint16DeltaBuilder creates a new Uint16DeltaBuilder.

func (*Uint16DeltaBuilder) Append 

func (b *Uint16DeltaBuilder) Append(value uint16)

func (*Uint16DeltaBuilder) AppendNull 

func (b *Uint16DeltaBuilder) AppendNull()

func (*Uint16DeltaBuilder) SetMaxDelta 

func (b *Uint16DeltaBuilder) SetMaxDelta(delta uint16)

type Uint32Builder 

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

Uint32Builder is a wrapper around the arrow array builder for uint32.

func (*Uint32Builder) Append 

func (b *Uint32Builder) Append(value uint32)

func (*Uint32Builder) AppendNonZero 

func (b *Uint32Builder) AppendNonZero(value uint32)

func (*Uint32Builder) AppendNull 

func (b *Uint32Builder) AppendNull()

type Uint32DeltaBuilder 

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

Uint32DeltaBuilder is a wrapper around the arrow array builder for uint32 with delta encoding.

func NewUint32DeltaBuilder 

func NewUint32DeltaBuilder(b array.Builder, transformNode *schema.TransformNode, updateReq *update.SchemaUpdateRequest) *Uint32DeltaBuilder

NewUint32DeltaBuilder creates a new Uint16DeltaBuilder.

func (*Uint32DeltaBuilder) Append 

func (b *Uint32DeltaBuilder) Append(value uint32)

func (*Uint32DeltaBuilder) AppendNull 

func (b *Uint32DeltaBuilder) AppendNull()

func (*Uint32DeltaBuilder) SetMaxDelta 

func (b *Uint32DeltaBuilder) SetMaxDelta(delta uint32)

type Uint64Builder 

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

Uint64Builder is a wrapper around the arrow array builder for uint64.

func (*Uint64Builder) Append 

func (b *Uint64Builder) Append(value uint64)

func (*Uint64Builder) AppendNonZero 

func (b *Uint64Builder) AppendNonZero(value uint64)

func (*Uint64Builder) AppendNull 

func (b *Uint64Builder) AppendNull()

type Uint8Builder 

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

Uint8Builder is a wrapper around the arrow array builder for uint8.

func (*Uint8Builder) Append 

func (b *Uint8Builder) Append(value uint8)

func (*Uint8Builder) AppendNonZero 

func (b *Uint8Builder) AppendNonZero(value uint8)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.