Documentation ¶
Index ¶
- Variables
- func BinaryEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func BinaryStart(builder *flatbuffers.Builder)
- func BodyCompressionAddCodec(builder *flatbuffers.Builder, codec CompressionType)
- func BodyCompressionAddMethod(builder *flatbuffers.Builder, method BodyCompressionMethod)
- func BodyCompressionEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func BodyCompressionStart(builder *flatbuffers.Builder)
- func BoolEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func BoolStart(builder *flatbuffers.Builder)
- func CreateBlock(builder *flatbuffers.Builder, offset int64, metaDataLength int32, ...) flatbuffers.UOffsetT
- func CreateBuffer(builder *flatbuffers.Builder, offset int64, length int64) flatbuffers.UOffsetT
- func CreateFieldNode(builder *flatbuffers.Builder, length int64, nullCount int64) flatbuffers.UOffsetT
- func DateAddUnit(builder *flatbuffers.Builder, unit DateUnit)
- func DateEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func DateStart(builder *flatbuffers.Builder)
- func DecimalAddBitWidth(builder *flatbuffers.Builder, bitWidth int32)
- func DecimalAddPrecision(builder *flatbuffers.Builder, precision int32)
- func DecimalAddScale(builder *flatbuffers.Builder, scale int32)
- func DecimalEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func DecimalStart(builder *flatbuffers.Builder)
- func DictionaryBatchAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
- func DictionaryBatchAddId(builder *flatbuffers.Builder, id int64)
- func DictionaryBatchAddIsDelta(builder *flatbuffers.Builder, isDelta bool)
- func DictionaryBatchEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func DictionaryBatchStart(builder *flatbuffers.Builder)
- func DictionaryEncodingAddDictionaryKind(builder *flatbuffers.Builder, dictionaryKind DictionaryKind)
- func DictionaryEncodingAddId(builder *flatbuffers.Builder, id int64)
- func DictionaryEncodingAddIndexType(builder *flatbuffers.Builder, indexType flatbuffers.UOffsetT)
- func DictionaryEncodingAddIsOrdered(builder *flatbuffers.Builder, isOrdered bool)
- func DictionaryEncodingEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func DictionaryEncodingStart(builder *flatbuffers.Builder)
- func DurationAddUnit(builder *flatbuffers.Builder, unit TimeUnit)
- func DurationEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func DurationStart(builder *flatbuffers.Builder)
- func FieldAddChildren(builder *flatbuffers.Builder, children flatbuffers.UOffsetT)
- func FieldAddCustomMetadata(builder *flatbuffers.Builder, customMetadata flatbuffers.UOffsetT)
- func FieldAddDictionary(builder *flatbuffers.Builder, dictionary flatbuffers.UOffsetT)
- func FieldAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)
- func FieldAddNullable(builder *flatbuffers.Builder, nullable bool)
- func FieldAddType(builder *flatbuffers.Builder, type_ flatbuffers.UOffsetT)
- func FieldAddTypeType(builder *flatbuffers.Builder, typeType Type)
- func FieldEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func FieldStart(builder *flatbuffers.Builder)
- func FieldStartChildrenVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func FieldStartCustomMetadataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func FixedSizeBinaryAddByteWidth(builder *flatbuffers.Builder, byteWidth int32)
- func FixedSizeBinaryEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func FixedSizeBinaryStart(builder *flatbuffers.Builder)
- func FixedSizeListAddListSize(builder *flatbuffers.Builder, listSize int32)
- func FixedSizeListEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func FixedSizeListStart(builder *flatbuffers.Builder)
- func FloatingPointAddPrecision(builder *flatbuffers.Builder, precision Precision)
- func FloatingPointEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func FloatingPointStart(builder *flatbuffers.Builder)
- func FooterAddCustomMetadata(builder *flatbuffers.Builder, customMetadata flatbuffers.UOffsetT)
- func FooterAddDictionaries(builder *flatbuffers.Builder, dictionaries flatbuffers.UOffsetT)
- func FooterAddRecordBatches(builder *flatbuffers.Builder, recordBatches flatbuffers.UOffsetT)
- func FooterAddSchema(builder *flatbuffers.Builder, schema flatbuffers.UOffsetT)
- func FooterAddVersion(builder *flatbuffers.Builder, version MetadataVersion)
- func FooterEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func FooterStart(builder *flatbuffers.Builder)
- func FooterStartCustomMetadataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func FooterStartDictionariesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func FooterStartRecordBatchesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func IntAddBitWidth(builder *flatbuffers.Builder, bitWidth int32)
- func IntAddIsSigned(builder *flatbuffers.Builder, isSigned bool)
- func IntEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func IntStart(builder *flatbuffers.Builder)
- func IntervalAddUnit(builder *flatbuffers.Builder, unit IntervalUnit)
- func IntervalEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func IntervalStart(builder *flatbuffers.Builder)
- func KeyValueAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
- func KeyValueAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
- func KeyValueEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func KeyValueStart(builder *flatbuffers.Builder)
- func LargeBinaryEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func LargeBinaryStart(builder *flatbuffers.Builder)
- func LargeListEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func LargeListStart(builder *flatbuffers.Builder)
- func LargeUtf8End(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func LargeUtf8Start(builder *flatbuffers.Builder)
- func ListEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func ListStart(builder *flatbuffers.Builder)
- func MapAddKeysSorted(builder *flatbuffers.Builder, keysSorted bool)
- func MapEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func MapStart(builder *flatbuffers.Builder)
- func MessageAddBodyLength(builder *flatbuffers.Builder, bodyLength int64)
- func MessageAddCustomMetadata(builder *flatbuffers.Builder, customMetadata flatbuffers.UOffsetT)
- func MessageAddHeader(builder *flatbuffers.Builder, header flatbuffers.UOffsetT)
- func MessageAddHeaderType(builder *flatbuffers.Builder, headerType MessageHeader)
- func MessageAddVersion(builder *flatbuffers.Builder, version MetadataVersion)
- func MessageEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func MessageStart(builder *flatbuffers.Builder)
- func MessageStartCustomMetadataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func NullEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func NullStart(builder *flatbuffers.Builder)
- func RecordBatchAddBuffers(builder *flatbuffers.Builder, buffers flatbuffers.UOffsetT)
- func RecordBatchAddCompression(builder *flatbuffers.Builder, compression flatbuffers.UOffsetT)
- func RecordBatchAddLength(builder *flatbuffers.Builder, length int64)
- func RecordBatchAddNodes(builder *flatbuffers.Builder, nodes flatbuffers.UOffsetT)
- func RecordBatchEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func RecordBatchStart(builder *flatbuffers.Builder)
- func RecordBatchStartBuffersVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func RecordBatchStartNodesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func SchemaAddCustomMetadata(builder *flatbuffers.Builder, customMetadata flatbuffers.UOffsetT)
- func SchemaAddEndianness(builder *flatbuffers.Builder, endianness Endianness)
- func SchemaAddFeatures(builder *flatbuffers.Builder, features flatbuffers.UOffsetT)
- func SchemaAddFields(builder *flatbuffers.Builder, fields flatbuffers.UOffsetT)
- func SchemaEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func SchemaStart(builder *flatbuffers.Builder)
- func SchemaStartCustomMetadataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func SchemaStartFeaturesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func SchemaStartFieldsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func SparseMatrixIndexCSRAddIndicesBuffer(builder *flatbuffers.Builder, indicesBuffer flatbuffers.UOffsetT)
- func SparseMatrixIndexCSRAddIndicesType(builder *flatbuffers.Builder, indicesType flatbuffers.UOffsetT)
- func SparseMatrixIndexCSRAddIndptrBuffer(builder *flatbuffers.Builder, indptrBuffer flatbuffers.UOffsetT)
- func SparseMatrixIndexCSRAddIndptrType(builder *flatbuffers.Builder, indptrType flatbuffers.UOffsetT)
- func SparseMatrixIndexCSREnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func SparseMatrixIndexCSRStart(builder *flatbuffers.Builder)
- func SparseMatrixIndexCSXAddCompressedAxis(builder *flatbuffers.Builder, compressedAxis SparseMatrixCompressedAxis)
- func SparseMatrixIndexCSXAddIndicesBuffer(builder *flatbuffers.Builder, indicesBuffer flatbuffers.UOffsetT)
- func SparseMatrixIndexCSXAddIndicesType(builder *flatbuffers.Builder, indicesType flatbuffers.UOffsetT)
- func SparseMatrixIndexCSXAddIndptrBuffer(builder *flatbuffers.Builder, indptrBuffer flatbuffers.UOffsetT)
- func SparseMatrixIndexCSXAddIndptrType(builder *flatbuffers.Builder, indptrType flatbuffers.UOffsetT)
- func SparseMatrixIndexCSXEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func SparseMatrixIndexCSXStart(builder *flatbuffers.Builder)
- func SparseTensorAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
- func SparseTensorAddNonZeroLength(builder *flatbuffers.Builder, nonZeroLength int64)
- func SparseTensorAddShape(builder *flatbuffers.Builder, shape flatbuffers.UOffsetT)
- func SparseTensorAddSparseIndex(builder *flatbuffers.Builder, sparseIndex flatbuffers.UOffsetT)
- func SparseTensorAddSparseIndexType(builder *flatbuffers.Builder, sparseIndexType SparseTensorIndex)
- func SparseTensorAddType(builder *flatbuffers.Builder, type_ flatbuffers.UOffsetT)
- func SparseTensorAddTypeType(builder *flatbuffers.Builder, typeType Type)
- func SparseTensorEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func SparseTensorIndexCOOAddIndicesBuffer(builder *flatbuffers.Builder, indicesBuffer flatbuffers.UOffsetT)
- func SparseTensorIndexCOOAddIndicesStrides(builder *flatbuffers.Builder, indicesStrides flatbuffers.UOffsetT)
- func SparseTensorIndexCOOAddIndicesType(builder *flatbuffers.Builder, indicesType flatbuffers.UOffsetT)
- func SparseTensorIndexCOOAddIsCanonical(builder *flatbuffers.Builder, isCanonical bool)
- func SparseTensorIndexCOOEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func SparseTensorIndexCOOStart(builder *flatbuffers.Builder)
- func SparseTensorIndexCOOStartIndicesStridesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func SparseTensorIndexCSFAddAxisOrder(builder *flatbuffers.Builder, axisOrder flatbuffers.UOffsetT)
- func SparseTensorIndexCSFAddIndicesBuffers(builder *flatbuffers.Builder, indicesBuffers flatbuffers.UOffsetT)
- func SparseTensorIndexCSFAddIndicesType(builder *flatbuffers.Builder, indicesType flatbuffers.UOffsetT)
- func SparseTensorIndexCSFAddIndptrBuffers(builder *flatbuffers.Builder, indptrBuffers flatbuffers.UOffsetT)
- func SparseTensorIndexCSFAddIndptrType(builder *flatbuffers.Builder, indptrType flatbuffers.UOffsetT)
- func SparseTensorIndexCSFEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func SparseTensorIndexCSFStart(builder *flatbuffers.Builder)
- func SparseTensorIndexCSFStartAxisOrderVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func SparseTensorIndexCSFStartIndicesBuffersVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func SparseTensorIndexCSFStartIndptrBuffersVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func SparseTensorStart(builder *flatbuffers.Builder)
- func SparseTensorStartShapeVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func Struct_End(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func Struct_Start(builder *flatbuffers.Builder)
- func TensorAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
- func TensorAddShape(builder *flatbuffers.Builder, shape flatbuffers.UOffsetT)
- func TensorAddStrides(builder *flatbuffers.Builder, strides flatbuffers.UOffsetT)
- func TensorAddType(builder *flatbuffers.Builder, type_ flatbuffers.UOffsetT)
- func TensorAddTypeType(builder *flatbuffers.Builder, typeType Type)
- func TensorDimAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)
- func TensorDimAddSize(builder *flatbuffers.Builder, size int64)
- func TensorDimEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func TensorDimStart(builder *flatbuffers.Builder)
- func TensorEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func TensorStart(builder *flatbuffers.Builder)
- func TensorStartShapeVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func TensorStartStridesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func TimeAddBitWidth(builder *flatbuffers.Builder, bitWidth int32)
- func TimeAddUnit(builder *flatbuffers.Builder, unit TimeUnit)
- func TimeEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func TimeStart(builder *flatbuffers.Builder)
- func TimestampAddTimezone(builder *flatbuffers.Builder, timezone flatbuffers.UOffsetT)
- func TimestampAddUnit(builder *flatbuffers.Builder, unit TimeUnit)
- func TimestampEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func TimestampStart(builder *flatbuffers.Builder)
- func UnionAddMode(builder *flatbuffers.Builder, mode UnionMode)
- func UnionAddTypeIds(builder *flatbuffers.Builder, typeIds flatbuffers.UOffsetT)
- func UnionEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func UnionStart(builder *flatbuffers.Builder)
- func UnionStartTypeIdsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func Utf8End(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func Utf8Start(builder *flatbuffers.Builder)
- type Binary
- type Block
- func (rcv *Block) BodyLength() int64
- func (rcv *Block) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Block) MetaDataLength() int32
- func (rcv *Block) MutateBodyLength(n int64) bool
- func (rcv *Block) MutateMetaDataLength(n int32) bool
- func (rcv *Block) MutateOffset(n int64) bool
- func (rcv *Block) Offset() int64
- func (rcv *Block) Table() flatbuffers.Table
- type BodyCompression
- func (rcv *BodyCompression) Codec() CompressionType
- func (rcv *BodyCompression) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *BodyCompression) Method() BodyCompressionMethod
- func (rcv *BodyCompression) MutateCodec(n CompressionType) bool
- func (rcv *BodyCompression) MutateMethod(n BodyCompressionMethod) bool
- func (rcv *BodyCompression) Table() flatbuffers.Table
- type BodyCompressionMethod
- type Bool
- type Buffer
- type CompressionType
- type Date
- type DateUnit
- type Decimal
- func (rcv *Decimal) BitWidth() int32
- func (rcv *Decimal) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Decimal) MutateBitWidth(n int32) bool
- func (rcv *Decimal) MutatePrecision(n int32) bool
- func (rcv *Decimal) MutateScale(n int32) bool
- func (rcv *Decimal) Precision() int32
- func (rcv *Decimal) Scale() int32
- func (rcv *Decimal) Table() flatbuffers.Table
- type DictionaryBatch
- func (rcv *DictionaryBatch) Data(obj *RecordBatch) *RecordBatch
- func (rcv *DictionaryBatch) Id() int64
- func (rcv *DictionaryBatch) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *DictionaryBatch) IsDelta() bool
- func (rcv *DictionaryBatch) MutateId(n int64) bool
- func (rcv *DictionaryBatch) MutateIsDelta(n bool) bool
- func (rcv *DictionaryBatch) Table() flatbuffers.Table
- type DictionaryEncoding
- func (rcv *DictionaryEncoding) DictionaryKind() DictionaryKind
- func (rcv *DictionaryEncoding) Id() int64
- func (rcv *DictionaryEncoding) IndexType(obj *Int) *Int
- func (rcv *DictionaryEncoding) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *DictionaryEncoding) IsOrdered() bool
- func (rcv *DictionaryEncoding) MutateDictionaryKind(n DictionaryKind) bool
- func (rcv *DictionaryEncoding) MutateId(n int64) bool
- func (rcv *DictionaryEncoding) MutateIsOrdered(n bool) bool
- func (rcv *DictionaryEncoding) Table() flatbuffers.Table
- type DictionaryKind
- type Duration
- type Endianness
- type Feature
- type Field
- func (rcv *Field) Children(obj *Field, j int) bool
- func (rcv *Field) ChildrenLength() int
- func (rcv *Field) CustomMetadata(obj *KeyValue, j int) bool
- func (rcv *Field) CustomMetadataLength() int
- func (rcv *Field) Dictionary(obj *DictionaryEncoding) *DictionaryEncoding
- func (rcv *Field) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Field) MutateNullable(n bool) bool
- func (rcv *Field) MutateTypeType(n Type) bool
- func (rcv *Field) Name() []byte
- func (rcv *Field) Nullable() bool
- func (rcv *Field) Table() flatbuffers.Table
- func (rcv *Field) Type(obj *flatbuffers.Table) bool
- func (rcv *Field) TypeType() Type
- type FieldNode
- type FixedSizeBinary
- type FixedSizeList
- type FloatingPoint
- type Footer
- func (rcv *Footer) CustomMetadata(obj *KeyValue, j int) bool
- func (rcv *Footer) CustomMetadataLength() int
- func (rcv *Footer) Dictionaries(obj *Block, j int) bool
- func (rcv *Footer) DictionariesLength() int
- func (rcv *Footer) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Footer) MutateVersion(n MetadataVersion) bool
- func (rcv *Footer) RecordBatches(obj *Block, j int) bool
- func (rcv *Footer) RecordBatchesLength() int
- func (rcv *Footer) Schema(obj *Schema) *Schema
- func (rcv *Footer) Table() flatbuffers.Table
- func (rcv *Footer) Version() MetadataVersion
- type Int
- type Interval
- type IntervalUnit
- type KeyValue
- type LargeBinary
- type LargeList
- type LargeUtf8
- type List
- type Map
- type Message
- func (rcv *Message) BodyLength() int64
- func (rcv *Message) CustomMetadata(obj *KeyValue, j int) bool
- func (rcv *Message) CustomMetadataLength() int
- func (rcv *Message) Header(obj *flatbuffers.Table) bool
- func (rcv *Message) HeaderType() MessageHeader
- func (rcv *Message) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Message) MutateBodyLength(n int64) bool
- func (rcv *Message) MutateHeaderType(n MessageHeader) bool
- func (rcv *Message) MutateVersion(n MetadataVersion) bool
- func (rcv *Message) Table() flatbuffers.Table
- func (rcv *Message) Version() MetadataVersion
- type MessageHeader
- type MetadataVersion
- type Null
- type Precision
- type RecordBatch
- func (rcv *RecordBatch) Buffers(obj *Buffer, j int) bool
- func (rcv *RecordBatch) BuffersLength() int
- func (rcv *RecordBatch) Compression(obj *BodyCompression) *BodyCompression
- func (rcv *RecordBatch) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *RecordBatch) Length() int64
- func (rcv *RecordBatch) MutateLength(n int64) bool
- func (rcv *RecordBatch) Nodes(obj *FieldNode, j int) bool
- func (rcv *RecordBatch) NodesLength() int
- func (rcv *RecordBatch) Table() flatbuffers.Table
- type Schema
- func (rcv *Schema) CustomMetadata(obj *KeyValue, j int) bool
- func (rcv *Schema) CustomMetadataLength() int
- func (rcv *Schema) Endianness() Endianness
- func (rcv *Schema) Features(j int) Feature
- func (rcv *Schema) FeaturesLength() int
- func (rcv *Schema) Fields(obj *Field, j int) bool
- func (rcv *Schema) FieldsLength() int
- func (rcv *Schema) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Schema) MutateEndianness(n Endianness) bool
- func (rcv *Schema) MutateFeatures(j int, n Feature) bool
- func (rcv *Schema) Table() flatbuffers.Table
- type SparseMatrixCompressedAxis
- type SparseMatrixIndexCSR
- func (rcv *SparseMatrixIndexCSR) IndicesBuffer(obj *Buffer) *Buffer
- func (rcv *SparseMatrixIndexCSR) IndicesType(obj *Int) *Int
- func (rcv *SparseMatrixIndexCSR) IndptrBuffer(obj *Buffer) *Buffer
- func (rcv *SparseMatrixIndexCSR) IndptrType(obj *Int) *Int
- func (rcv *SparseMatrixIndexCSR) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *SparseMatrixIndexCSR) Table() flatbuffers.Table
- type SparseMatrixIndexCSX
- func (rcv *SparseMatrixIndexCSX) CompressedAxis() SparseMatrixCompressedAxis
- func (rcv *SparseMatrixIndexCSX) IndicesBuffer(obj *Buffer) *Buffer
- func (rcv *SparseMatrixIndexCSX) IndicesType(obj *Int) *Int
- func (rcv *SparseMatrixIndexCSX) IndptrBuffer(obj *Buffer) *Buffer
- func (rcv *SparseMatrixIndexCSX) IndptrType(obj *Int) *Int
- func (rcv *SparseMatrixIndexCSX) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *SparseMatrixIndexCSX) MutateCompressedAxis(n SparseMatrixCompressedAxis) bool
- func (rcv *SparseMatrixIndexCSX) Table() flatbuffers.Table
- type SparseTensor
- func (rcv *SparseTensor) Data(obj *Buffer) *Buffer
- func (rcv *SparseTensor) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *SparseTensor) MutateNonZeroLength(n int64) bool
- func (rcv *SparseTensor) MutateSparseIndexType(n SparseTensorIndex) bool
- func (rcv *SparseTensor) MutateTypeType(n Type) bool
- func (rcv *SparseTensor) NonZeroLength() int64
- func (rcv *SparseTensor) Shape(obj *TensorDim, j int) bool
- func (rcv *SparseTensor) ShapeLength() int
- func (rcv *SparseTensor) SparseIndex(obj *flatbuffers.Table) bool
- func (rcv *SparseTensor) SparseIndexType() SparseTensorIndex
- func (rcv *SparseTensor) Table() flatbuffers.Table
- func (rcv *SparseTensor) Type(obj *flatbuffers.Table) bool
- func (rcv *SparseTensor) TypeType() Type
- type SparseTensorIndex
- type SparseTensorIndexCOO
- func (rcv *SparseTensorIndexCOO) IndicesBuffer(obj *Buffer) *Buffer
- func (rcv *SparseTensorIndexCOO) IndicesStrides(j int) int64
- func (rcv *SparseTensorIndexCOO) IndicesStridesLength() int
- func (rcv *SparseTensorIndexCOO) IndicesType(obj *Int) *Int
- func (rcv *SparseTensorIndexCOO) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *SparseTensorIndexCOO) IsCanonical() bool
- func (rcv *SparseTensorIndexCOO) MutateIndicesStrides(j int, n int64) bool
- func (rcv *SparseTensorIndexCOO) MutateIsCanonical(n bool) bool
- func (rcv *SparseTensorIndexCOO) Table() flatbuffers.Table
- type SparseTensorIndexCSF
- func (rcv *SparseTensorIndexCSF) AxisOrder(j int) int32
- func (rcv *SparseTensorIndexCSF) AxisOrderLength() int
- func (rcv *SparseTensorIndexCSF) IndicesBuffers(obj *Buffer, j int) bool
- func (rcv *SparseTensorIndexCSF) IndicesBuffersLength() int
- func (rcv *SparseTensorIndexCSF) IndicesType(obj *Int) *Int
- func (rcv *SparseTensorIndexCSF) IndptrBuffers(obj *Buffer, j int) bool
- func (rcv *SparseTensorIndexCSF) IndptrBuffersLength() int
- func (rcv *SparseTensorIndexCSF) IndptrType(obj *Int) *Int
- func (rcv *SparseTensorIndexCSF) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *SparseTensorIndexCSF) MutateAxisOrder(j int, n int32) bool
- func (rcv *SparseTensorIndexCSF) Table() flatbuffers.Table
- type Struct_
- type Tensor
- func (rcv *Tensor) Data(obj *Buffer) *Buffer
- func (rcv *Tensor) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Tensor) MutateStrides(j int, n int64) bool
- func (rcv *Tensor) MutateTypeType(n Type) bool
- func (rcv *Tensor) Shape(obj *TensorDim, j int) bool
- func (rcv *Tensor) ShapeLength() int
- func (rcv *Tensor) Strides(j int) int64
- func (rcv *Tensor) StridesLength() int
- func (rcv *Tensor) Table() flatbuffers.Table
- func (rcv *Tensor) Type(obj *flatbuffers.Table) bool
- func (rcv *Tensor) TypeType() Type
- type TensorDim
- type Time
- type TimeUnit
- type Timestamp
- type Type
- type Union
- func (rcv *Union) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Union) Mode() UnionMode
- func (rcv *Union) MutateMode(n UnionMode) bool
- func (rcv *Union) MutateTypeIds(j int, n int32) bool
- func (rcv *Union) Table() flatbuffers.Table
- func (rcv *Union) TypeIds(j int) int32
- func (rcv *Union) TypeIdsLength() int
- type UnionMode
- type Utf8
Constants ¶
This section is empty.
Variables ¶
var EnumNamesBodyCompressionMethod = map[BodyCompressionMethod]string{ BodyCompressionMethodBUFFER: "BUFFER", }
var EnumNamesCompressionType = map[CompressionType]string{ CompressionTypeLZ4_FRAME: "LZ4_FRAME", CompressionTypeZSTD: "ZSTD", }
var EnumNamesDateUnit = map[DateUnit]string{ DateUnitDAY: "DAY", DateUnitMILLISECOND: "MILLISECOND", }
var EnumNamesDictionaryKind = map[DictionaryKind]string{ DictionaryKindDenseArray: "DenseArray", }
var EnumNamesEndianness = map[Endianness]string{ EndiannessLittle: "Little", EndiannessBig: "Big", }
var EnumNamesFeature = map[Feature]string{ FeatureUNUSED: "UNUSED", FeatureDICTIONARY_REPLACEMENT: "DICTIONARY_REPLACEMENT", FeatureCOMPRESSED_BODY: "COMPRESSED_BODY", }
var EnumNamesIntervalUnit = map[IntervalUnit]string{ IntervalUnitYEAR_MONTH: "YEAR_MONTH", IntervalUnitDAY_TIME: "DAY_TIME", IntervalUnitMONTH_DAY_NANO: "MONTH_DAY_NANO", }
var EnumNamesMessageHeader = map[MessageHeader]string{ MessageHeaderNONE: "NONE", MessageHeaderSchema: "Schema", MessageHeaderDictionaryBatch: "DictionaryBatch", MessageHeaderRecordBatch: "RecordBatch", MessageHeaderTensor: "Tensor", MessageHeaderSparseTensor: "SparseTensor", }
var EnumNamesMetadataVersion = map[MetadataVersion]string{ MetadataVersionV1: "V1", MetadataVersionV2: "V2", MetadataVersionV3: "V3", MetadataVersionV4: "V4", MetadataVersionV5: "V5", }
var EnumNamesPrecision = map[Precision]string{ PrecisionHALF: "HALF", PrecisionSINGLE: "SINGLE", PrecisionDOUBLE: "DOUBLE", }
var EnumNamesSparseMatrixCompressedAxis = map[SparseMatrixCompressedAxis]string{ SparseMatrixCompressedAxisRow: "Row", SparseMatrixCompressedAxisColumn: "Column", }
var EnumNamesSparseTensorIndex = map[SparseTensorIndex]string{ SparseTensorIndexNONE: "NONE", SparseTensorIndexSparseTensorIndexCOO: "SparseTensorIndexCOO", SparseTensorIndexSparseMatrixIndexCSX: "SparseMatrixIndexCSX", SparseTensorIndexSparseTensorIndexCSF: "SparseTensorIndexCSF", }
var EnumNamesTimeUnit = map[TimeUnit]string{ TimeUnitSECOND: "SECOND", TimeUnitMILLISECOND: "MILLISECOND", TimeUnitMICROSECOND: "MICROSECOND", TimeUnitNANOSECOND: "NANOSECOND", }
var EnumNamesType = map[Type]string{ TypeNONE: "NONE", TypeNull: "Null", TypeInt: "Int", TypeFloatingPoint: "FloatingPoint", TypeBinary: "Binary", TypeUtf8: "Utf8", TypeBool: "Bool", TypeDecimal: "Decimal", TypeDate: "Date", TypeTime: "Time", TypeTimestamp: "Timestamp", TypeInterval: "Interval", TypeList: "List", TypeStruct_: "Struct_", TypeUnion: "Union", TypeFixedSizeBinary: "FixedSizeBinary", TypeFixedSizeList: "FixedSizeList", TypeMap: "Map", TypeDuration: "Duration", TypeLargeBinary: "LargeBinary", TypeLargeUtf8: "LargeUtf8", TypeLargeList: "LargeList", }
var EnumNamesUnionMode = map[UnionMode]string{ UnionModeSparse: "Sparse", UnionModeDense: "Dense", }
var EnumValuesBodyCompressionMethod = map[string]BodyCompressionMethod{ "BUFFER": BodyCompressionMethodBUFFER, }
var EnumValuesCompressionType = map[string]CompressionType{ "LZ4_FRAME": CompressionTypeLZ4_FRAME, "ZSTD": CompressionTypeZSTD, }
var EnumValuesDateUnit = map[string]DateUnit{ "DAY": DateUnitDAY, "MILLISECOND": DateUnitMILLISECOND, }
var EnumValuesDictionaryKind = map[string]DictionaryKind{ "DenseArray": DictionaryKindDenseArray, }
var EnumValuesEndianness = map[string]Endianness{ "Little": EndiannessLittle, "Big": EndiannessBig, }
var EnumValuesFeature = map[string]Feature{ "UNUSED": FeatureUNUSED, "DICTIONARY_REPLACEMENT": FeatureDICTIONARY_REPLACEMENT, "COMPRESSED_BODY": FeatureCOMPRESSED_BODY, }
var EnumValuesIntervalUnit = map[string]IntervalUnit{ "YEAR_MONTH": IntervalUnitYEAR_MONTH, "DAY_TIME": IntervalUnitDAY_TIME, "MONTH_DAY_NANO": IntervalUnitMONTH_DAY_NANO, }
var EnumValuesMessageHeader = map[string]MessageHeader{ "NONE": MessageHeaderNONE, "Schema": MessageHeaderSchema, "DictionaryBatch": MessageHeaderDictionaryBatch, "RecordBatch": MessageHeaderRecordBatch, "Tensor": MessageHeaderTensor, "SparseTensor": MessageHeaderSparseTensor, }
var EnumValuesMetadataVersion = map[string]MetadataVersion{ "V1": MetadataVersionV1, "V2": MetadataVersionV2, "V3": MetadataVersionV3, "V4": MetadataVersionV4, "V5": MetadataVersionV5, }
var EnumValuesPrecision = map[string]Precision{ "HALF": PrecisionHALF, "SINGLE": PrecisionSINGLE, "DOUBLE": PrecisionDOUBLE, }
var EnumValuesSparseMatrixCompressedAxis = map[string]SparseMatrixCompressedAxis{ "Row": SparseMatrixCompressedAxisRow, "Column": SparseMatrixCompressedAxisColumn, }
var EnumValuesSparseTensorIndex = map[string]SparseTensorIndex{ "NONE": SparseTensorIndexNONE, "SparseTensorIndexCOO": SparseTensorIndexSparseTensorIndexCOO, "SparseMatrixIndexCSX": SparseTensorIndexSparseMatrixIndexCSX, "SparseTensorIndexCSF": SparseTensorIndexSparseTensorIndexCSF, }
var EnumValuesTimeUnit = map[string]TimeUnit{ "SECOND": TimeUnitSECOND, "MILLISECOND": TimeUnitMILLISECOND, "MICROSECOND": TimeUnitMICROSECOND, "NANOSECOND": TimeUnitNANOSECOND, }
var EnumValuesType = map[string]Type{ "NONE": TypeNONE, "Null": TypeNull, "Int": TypeInt, "FloatingPoint": TypeFloatingPoint, "Binary": TypeBinary, "Utf8": TypeUtf8, "Bool": TypeBool, "Decimal": TypeDecimal, "Date": TypeDate, "Time": TypeTime, "Timestamp": TypeTimestamp, "Interval": TypeInterval, "List": TypeList, "Struct_": TypeStruct_, "Union": TypeUnion, "FixedSizeBinary": TypeFixedSizeBinary, "FixedSizeList": TypeFixedSizeList, "Map": TypeMap, "Duration": TypeDuration, "LargeBinary": TypeLargeBinary, "LargeUtf8": TypeLargeUtf8, "LargeList": TypeLargeList, }
var EnumValuesUnionMode = map[string]UnionMode{ "Sparse": UnionModeSparse, "Dense": UnionModeDense, }
Functions ¶
func BinaryEnd ¶
func BinaryEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func BinaryStart ¶
func BinaryStart(builder *flatbuffers.Builder)
func BodyCompressionAddCodec ¶
func BodyCompressionAddCodec(builder *flatbuffers.Builder, codec CompressionType)
func BodyCompressionAddMethod ¶
func BodyCompressionAddMethod(builder *flatbuffers.Builder, method BodyCompressionMethod)
func BodyCompressionEnd ¶
func BodyCompressionEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func BodyCompressionStart ¶
func BodyCompressionStart(builder *flatbuffers.Builder)
func BoolEnd ¶
func BoolEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func BoolStart ¶
func BoolStart(builder *flatbuffers.Builder)
func CreateBlock ¶
func CreateBlock(builder *flatbuffers.Builder, offset int64, metaDataLength int32, bodyLength int64) flatbuffers.UOffsetT
func CreateBuffer ¶
func CreateBuffer(builder *flatbuffers.Builder, offset int64, length int64) flatbuffers.UOffsetT
func CreateFieldNode ¶
func CreateFieldNode(builder *flatbuffers.Builder, length int64, nullCount int64) flatbuffers.UOffsetT
func DateAddUnit ¶
func DateAddUnit(builder *flatbuffers.Builder, unit DateUnit)
func DateEnd ¶
func DateEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func DateStart ¶
func DateStart(builder *flatbuffers.Builder)
func DecimalAddBitWidth ¶
func DecimalAddBitWidth(builder *flatbuffers.Builder, bitWidth int32)
func DecimalAddPrecision ¶
func DecimalAddPrecision(builder *flatbuffers.Builder, precision int32)
func DecimalAddScale ¶
func DecimalAddScale(builder *flatbuffers.Builder, scale int32)
func DecimalEnd ¶
func DecimalEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func DecimalStart ¶
func DecimalStart(builder *flatbuffers.Builder)
func DictionaryBatchAddData ¶
func DictionaryBatchAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
func DictionaryBatchAddId ¶
func DictionaryBatchAddId(builder *flatbuffers.Builder, id int64)
func DictionaryBatchAddIsDelta ¶
func DictionaryBatchAddIsDelta(builder *flatbuffers.Builder, isDelta bool)
func DictionaryBatchEnd ¶
func DictionaryBatchEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func DictionaryBatchStart ¶
func DictionaryBatchStart(builder *flatbuffers.Builder)
func DictionaryEncodingAddDictionaryKind ¶
func DictionaryEncodingAddDictionaryKind(builder *flatbuffers.Builder, dictionaryKind DictionaryKind)
func DictionaryEncodingAddId ¶
func DictionaryEncodingAddId(builder *flatbuffers.Builder, id int64)
func DictionaryEncodingAddIndexType ¶
func DictionaryEncodingAddIndexType(builder *flatbuffers.Builder, indexType flatbuffers.UOffsetT)
func DictionaryEncodingAddIsOrdered ¶
func DictionaryEncodingAddIsOrdered(builder *flatbuffers.Builder, isOrdered bool)
func DictionaryEncodingEnd ¶
func DictionaryEncodingEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func DictionaryEncodingStart ¶
func DictionaryEncodingStart(builder *flatbuffers.Builder)
func DurationAddUnit ¶
func DurationAddUnit(builder *flatbuffers.Builder, unit TimeUnit)
func DurationEnd ¶
func DurationEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func DurationStart ¶
func DurationStart(builder *flatbuffers.Builder)
func FieldAddChildren ¶
func FieldAddChildren(builder *flatbuffers.Builder, children flatbuffers.UOffsetT)
func FieldAddCustomMetadata ¶
func FieldAddCustomMetadata(builder *flatbuffers.Builder, customMetadata flatbuffers.UOffsetT)
func FieldAddDictionary ¶
func FieldAddDictionary(builder *flatbuffers.Builder, dictionary flatbuffers.UOffsetT)
func FieldAddName ¶
func FieldAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)
func FieldAddNullable ¶
func FieldAddNullable(builder *flatbuffers.Builder, nullable bool)
func FieldAddType ¶
func FieldAddType(builder *flatbuffers.Builder, type_ flatbuffers.UOffsetT)
func FieldAddTypeType ¶
func FieldAddTypeType(builder *flatbuffers.Builder, typeType Type)
func FieldEnd ¶
func FieldEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func FieldStartChildrenVector ¶
func FieldStartChildrenVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func FieldStartCustomMetadataVector ¶
func FieldStartCustomMetadataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func FixedSizeBinaryAddByteWidth ¶
func FixedSizeBinaryAddByteWidth(builder *flatbuffers.Builder, byteWidth int32)
func FixedSizeBinaryEnd ¶
func FixedSizeBinaryEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func FixedSizeBinaryStart ¶
func FixedSizeBinaryStart(builder *flatbuffers.Builder)
func FixedSizeListAddListSize ¶
func FixedSizeListAddListSize(builder *flatbuffers.Builder, listSize int32)
func FixedSizeListEnd ¶
func FixedSizeListEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func FixedSizeListStart ¶
func FixedSizeListStart(builder *flatbuffers.Builder)
func FloatingPointAddPrecision ¶
func FloatingPointAddPrecision(builder *flatbuffers.Builder, precision Precision)
func FloatingPointEnd ¶
func FloatingPointEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func FloatingPointStart ¶
func FloatingPointStart(builder *flatbuffers.Builder)
func FooterAddCustomMetadata ¶
func FooterAddCustomMetadata(builder *flatbuffers.Builder, customMetadata flatbuffers.UOffsetT)
func FooterAddDictionaries ¶
func FooterAddDictionaries(builder *flatbuffers.Builder, dictionaries flatbuffers.UOffsetT)
func FooterAddRecordBatches ¶
func FooterAddRecordBatches(builder *flatbuffers.Builder, recordBatches flatbuffers.UOffsetT)
func FooterAddSchema ¶
func FooterAddSchema(builder *flatbuffers.Builder, schema flatbuffers.UOffsetT)
func FooterAddVersion ¶
func FooterAddVersion(builder *flatbuffers.Builder, version MetadataVersion)
func FooterEnd ¶
func FooterEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func FooterStartCustomMetadataVector ¶
func FooterStartCustomMetadataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func FooterStartDictionariesVector ¶
func FooterStartDictionariesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func FooterStartRecordBatchesVector ¶
func FooterStartRecordBatchesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func IntAddBitWidth ¶
func IntAddBitWidth(builder *flatbuffers.Builder, bitWidth int32)
func IntAddIsSigned ¶
func IntAddIsSigned(builder *flatbuffers.Builder, isSigned bool)
func IntEnd ¶
func IntEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func IntStart ¶
func IntStart(builder *flatbuffers.Builder)
func IntervalAddUnit ¶
func IntervalAddUnit(builder *flatbuffers.Builder, unit IntervalUnit)
func IntervalEnd ¶
func IntervalEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func IntervalStart ¶
func IntervalStart(builder *flatbuffers.Builder)
func KeyValueAddKey ¶
func KeyValueAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
func KeyValueAddValue ¶
func KeyValueAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
func KeyValueEnd ¶
func KeyValueEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func KeyValueStart ¶
func KeyValueStart(builder *flatbuffers.Builder)
func LargeBinaryEnd ¶
func LargeBinaryEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func LargeBinaryStart ¶
func LargeBinaryStart(builder *flatbuffers.Builder)
func LargeListEnd ¶
func LargeListEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func LargeListStart ¶
func LargeListStart(builder *flatbuffers.Builder)
func LargeUtf8End ¶
func LargeUtf8End(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func LargeUtf8Start ¶
func LargeUtf8Start(builder *flatbuffers.Builder)
func ListEnd ¶
func ListEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func ListStart ¶
func ListStart(builder *flatbuffers.Builder)
func MapAddKeysSorted ¶
func MapAddKeysSorted(builder *flatbuffers.Builder, keysSorted bool)
func MapEnd ¶
func MapEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func MapStart ¶
func MapStart(builder *flatbuffers.Builder)
func MessageAddBodyLength ¶
func MessageAddBodyLength(builder *flatbuffers.Builder, bodyLength int64)
func MessageAddCustomMetadata ¶
func MessageAddCustomMetadata(builder *flatbuffers.Builder, customMetadata flatbuffers.UOffsetT)
func MessageAddHeader ¶
func MessageAddHeader(builder *flatbuffers.Builder, header flatbuffers.UOffsetT)
func MessageAddHeaderType ¶
func MessageAddHeaderType(builder *flatbuffers.Builder, headerType MessageHeader)
func MessageAddVersion ¶
func MessageAddVersion(builder *flatbuffers.Builder, version MetadataVersion)
func MessageEnd ¶
func MessageEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func MessageStart ¶
func MessageStart(builder *flatbuffers.Builder)
func MessageStartCustomMetadataVector ¶
func MessageStartCustomMetadataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func NullEnd ¶
func NullEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func NullStart ¶
func NullStart(builder *flatbuffers.Builder)
func RecordBatchAddBuffers ¶
func RecordBatchAddBuffers(builder *flatbuffers.Builder, buffers flatbuffers.UOffsetT)
func RecordBatchAddCompression ¶
func RecordBatchAddCompression(builder *flatbuffers.Builder, compression flatbuffers.UOffsetT)
func RecordBatchAddLength ¶
func RecordBatchAddLength(builder *flatbuffers.Builder, length int64)
func RecordBatchAddNodes ¶
func RecordBatchAddNodes(builder *flatbuffers.Builder, nodes flatbuffers.UOffsetT)
func RecordBatchEnd ¶
func RecordBatchEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func RecordBatchStart ¶
func RecordBatchStart(builder *flatbuffers.Builder)
/ Optional compression of the message body
func RecordBatchStartBuffersVector ¶
func RecordBatchStartBuffersVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func RecordBatchStartNodesVector ¶
func RecordBatchStartNodesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func SchemaAddCustomMetadata ¶
func SchemaAddCustomMetadata(builder *flatbuffers.Builder, customMetadata flatbuffers.UOffsetT)
func SchemaAddEndianness ¶
func SchemaAddEndianness(builder *flatbuffers.Builder, endianness Endianness)
func SchemaAddFeatures ¶
func SchemaAddFeatures(builder *flatbuffers.Builder, features flatbuffers.UOffsetT)
func SchemaAddFields ¶
func SchemaAddFields(builder *flatbuffers.Builder, fields flatbuffers.UOffsetT)
func SchemaEnd ¶
func SchemaEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func SchemaStart ¶
func SchemaStart(builder *flatbuffers.Builder)
func SchemaStartCustomMetadataVector ¶
func SchemaStartCustomMetadataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func SchemaStartFeaturesVector ¶
func SchemaStartFeaturesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func SchemaStartFieldsVector ¶
func SchemaStartFieldsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func SparseMatrixIndexCSRAddIndicesBuffer ¶
func SparseMatrixIndexCSRAddIndicesBuffer(builder *flatbuffers.Builder, indicesBuffer flatbuffers.UOffsetT)
func SparseMatrixIndexCSRAddIndicesType ¶
func SparseMatrixIndexCSRAddIndicesType(builder *flatbuffers.Builder, indicesType flatbuffers.UOffsetT)
func SparseMatrixIndexCSRAddIndptrBuffer ¶
func SparseMatrixIndexCSRAddIndptrBuffer(builder *flatbuffers.Builder, indptrBuffer flatbuffers.UOffsetT)
func SparseMatrixIndexCSRAddIndptrType ¶
func SparseMatrixIndexCSRAddIndptrType(builder *flatbuffers.Builder, indptrType flatbuffers.UOffsetT)
func SparseMatrixIndexCSREnd ¶
func SparseMatrixIndexCSREnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func SparseMatrixIndexCSRStart ¶
func SparseMatrixIndexCSRStart(builder *flatbuffers.Builder)
/ indicesBuffer stores the location and size of the array that / contains the column indices of the corresponding non-zero values. / The type of index value is long. / / For example, the indices of the above X is: / / indices(X) = [1, 2, 2, 1, 3, 0, 2, 3, 1]. / / Note that the indices are sorted in lexicographical order for each row.
func SparseMatrixIndexCSXAddCompressedAxis ¶
func SparseMatrixIndexCSXAddCompressedAxis(builder *flatbuffers.Builder, compressedAxis SparseMatrixCompressedAxis)
func SparseMatrixIndexCSXAddIndicesBuffer ¶
func SparseMatrixIndexCSXAddIndicesBuffer(builder *flatbuffers.Builder, indicesBuffer flatbuffers.UOffsetT)
func SparseMatrixIndexCSXAddIndicesType ¶
func SparseMatrixIndexCSXAddIndicesType(builder *flatbuffers.Builder, indicesType flatbuffers.UOffsetT)
func SparseMatrixIndexCSXAddIndptrBuffer ¶
func SparseMatrixIndexCSXAddIndptrBuffer(builder *flatbuffers.Builder, indptrBuffer flatbuffers.UOffsetT)
func SparseMatrixIndexCSXAddIndptrType ¶
func SparseMatrixIndexCSXAddIndptrType(builder *flatbuffers.Builder, indptrType flatbuffers.UOffsetT)
func SparseMatrixIndexCSXEnd ¶
func SparseMatrixIndexCSXEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func SparseMatrixIndexCSXStart ¶
func SparseMatrixIndexCSXStart(builder *flatbuffers.Builder)
/ indicesBuffer stores the location and size of the array that / contains the column indices of the corresponding non-zero values. / The type of index value is long. / / For example, the indices of the above X is: / ```text / indices(X) = [1, 2, 2, 1, 3, 0, 2, 3, 1]. / ``` / Note that the indices are sorted in lexicographical order for each row.
func SparseTensorAddData ¶
func SparseTensorAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
func SparseTensorAddNonZeroLength ¶
func SparseTensorAddNonZeroLength(builder *flatbuffers.Builder, nonZeroLength int64)
func SparseTensorAddShape ¶
func SparseTensorAddShape(builder *flatbuffers.Builder, shape flatbuffers.UOffsetT)
func SparseTensorAddSparseIndex ¶
func SparseTensorAddSparseIndex(builder *flatbuffers.Builder, sparseIndex flatbuffers.UOffsetT)
func SparseTensorAddSparseIndexType ¶
func SparseTensorAddSparseIndexType(builder *flatbuffers.Builder, sparseIndexType SparseTensorIndex)
func SparseTensorAddType ¶
func SparseTensorAddType(builder *flatbuffers.Builder, type_ flatbuffers.UOffsetT)
func SparseTensorAddTypeType ¶
func SparseTensorAddTypeType(builder *flatbuffers.Builder, typeType Type)
func SparseTensorEnd ¶
func SparseTensorEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func SparseTensorIndexCOOAddIndicesBuffer ¶
func SparseTensorIndexCOOAddIndicesBuffer(builder *flatbuffers.Builder, indicesBuffer flatbuffers.UOffsetT)
func SparseTensorIndexCOOAddIndicesStrides ¶
func SparseTensorIndexCOOAddIndicesStrides(builder *flatbuffers.Builder, indicesStrides flatbuffers.UOffsetT)
func SparseTensorIndexCOOAddIndicesType ¶
func SparseTensorIndexCOOAddIndicesType(builder *flatbuffers.Builder, indicesType flatbuffers.UOffsetT)
func SparseTensorIndexCOOAddIsCanonical ¶
func SparseTensorIndexCOOAddIsCanonical(builder *flatbuffers.Builder, isCanonical bool)
func SparseTensorIndexCOOEnd ¶
func SparseTensorIndexCOOEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func SparseTensorIndexCOOStart ¶
func SparseTensorIndexCOOStart(builder *flatbuffers.Builder)
func SparseTensorIndexCOOStartIndicesStridesVector ¶
func SparseTensorIndexCOOStartIndicesStridesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func SparseTensorIndexCSFAddAxisOrder ¶
func SparseTensorIndexCSFAddAxisOrder(builder *flatbuffers.Builder, axisOrder flatbuffers.UOffsetT)
func SparseTensorIndexCSFAddIndicesBuffers ¶
func SparseTensorIndexCSFAddIndicesBuffers(builder *flatbuffers.Builder, indicesBuffers flatbuffers.UOffsetT)
func SparseTensorIndexCSFAddIndicesType ¶
func SparseTensorIndexCSFAddIndicesType(builder *flatbuffers.Builder, indicesType flatbuffers.UOffsetT)
func SparseTensorIndexCSFAddIndptrBuffers ¶
func SparseTensorIndexCSFAddIndptrBuffers(builder *flatbuffers.Builder, indptrBuffers flatbuffers.UOffsetT)
func SparseTensorIndexCSFAddIndptrType ¶
func SparseTensorIndexCSFAddIndptrType(builder *flatbuffers.Builder, indptrType flatbuffers.UOffsetT)
func SparseTensorIndexCSFEnd ¶
func SparseTensorIndexCSFEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func SparseTensorIndexCSFStart ¶
func SparseTensorIndexCSFStart(builder *flatbuffers.Builder)
func SparseTensorIndexCSFStartAxisOrderVector ¶
func SparseTensorIndexCSFStartAxisOrderVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func SparseTensorIndexCSFStartIndicesBuffersVector ¶
func SparseTensorIndexCSFStartIndicesBuffersVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func SparseTensorIndexCSFStartIndptrBuffersVector ¶
func SparseTensorIndexCSFStartIndptrBuffersVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func SparseTensorStart ¶
func SparseTensorStart(builder *flatbuffers.Builder)
/ The location and size of the tensor's data
func SparseTensorStartShapeVector ¶
func SparseTensorStartShapeVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func Struct_End ¶
func Struct_End(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func Struct_Start ¶
func Struct_Start(builder *flatbuffers.Builder)
func TensorAddData ¶
func TensorAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
func TensorAddShape ¶
func TensorAddShape(builder *flatbuffers.Builder, shape flatbuffers.UOffsetT)
func TensorAddStrides ¶
func TensorAddStrides(builder *flatbuffers.Builder, strides flatbuffers.UOffsetT)
func TensorAddType ¶
func TensorAddType(builder *flatbuffers.Builder, type_ flatbuffers.UOffsetT)
func TensorAddTypeType ¶
func TensorAddTypeType(builder *flatbuffers.Builder, typeType Type)
func TensorDimAddName ¶
func TensorDimAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)
func TensorDimAddSize ¶
func TensorDimAddSize(builder *flatbuffers.Builder, size int64)
func TensorDimEnd ¶
func TensorDimEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func TensorDimStart ¶
func TensorDimStart(builder *flatbuffers.Builder)
/ Name of the dimension, optional
func TensorEnd ¶
func TensorEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func TensorStart ¶
func TensorStart(builder *flatbuffers.Builder)
/ The location and size of the tensor's data
func TensorStartShapeVector ¶
func TensorStartShapeVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func TensorStartStridesVector ¶
func TensorStartStridesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func TimeAddBitWidth ¶
func TimeAddBitWidth(builder *flatbuffers.Builder, bitWidth int32)
func TimeAddUnit ¶
func TimeAddUnit(builder *flatbuffers.Builder, unit TimeUnit)
func TimeEnd ¶
func TimeEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func TimeStart ¶
func TimeStart(builder *flatbuffers.Builder)
func TimestampAddTimezone ¶
func TimestampAddTimezone(builder *flatbuffers.Builder, timezone flatbuffers.UOffsetT)
func TimestampAddUnit ¶
func TimestampAddUnit(builder *flatbuffers.Builder, unit TimeUnit)
func TimestampEnd ¶
func TimestampEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func TimestampStart ¶
func TimestampStart(builder *flatbuffers.Builder)
/ The timezone is an optional string indicating the name of a timezone, / one of: / / * As used in the Olson timezone database (the "tz database" or / "tzdata"), such as "America/New_York". / * An absolute timezone offset of the form "+XX:XX" or "-XX:XX", / such as "+07:30". / / Whether a timezone string is present indicates different semantics about / the data (see above).
func UnionAddMode ¶
func UnionAddMode(builder *flatbuffers.Builder, mode UnionMode)
func UnionAddTypeIds ¶
func UnionAddTypeIds(builder *flatbuffers.Builder, typeIds flatbuffers.UOffsetT)
func UnionEnd ¶
func UnionEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func UnionStart ¶
func UnionStart(builder *flatbuffers.Builder)
func UnionStartTypeIdsVector ¶
func UnionStartTypeIdsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func Utf8End ¶
func Utf8End(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func Utf8Start ¶
func Utf8Start(builder *flatbuffers.Builder)
Types ¶
type Binary ¶
type Binary struct {
// contains filtered or unexported fields
}
/ Opaque binary data
func GetRootAsBinary ¶
func GetRootAsBinary(buf []byte, offset flatbuffers.UOffsetT) *Binary
func (*Binary) Table ¶
func (rcv *Binary) Table() flatbuffers.Table
type Block ¶
type Block struct {
// contains filtered or unexported fields
}
func (*Block) BodyLength ¶
/ Length of the data (this is aligned so there can be a gap between this and / the metadata).
func (*Block) MutateBodyLength ¶
/ Length of the data (this is aligned so there can be a gap between this and / the metadata).
func (*Block) MutateMetaDataLength ¶
/ Length of the metadata
func (*Block) MutateOffset ¶
/ Index to the start of the RecordBlock (note this is past the Message header)
func (*Block) Offset ¶
/ Index to the start of the RecordBlock (note this is past the Message header)
func (*Block) Table ¶
func (rcv *Block) Table() flatbuffers.Table
type BodyCompression ¶
type BodyCompression struct {
// contains filtered or unexported fields
}
/ Optional compression for the memory buffers constituting IPC message / bodies. Intended for use with RecordBatch but could be used for other / message types
func GetRootAsBodyCompression ¶
func GetRootAsBodyCompression(buf []byte, offset flatbuffers.UOffsetT) *BodyCompression
func (*BodyCompression) Codec ¶
func (rcv *BodyCompression) Codec() CompressionType
/ Compressor library
func (*BodyCompression) Init ¶
func (rcv *BodyCompression) Init(buf []byte, i flatbuffers.UOffsetT)
func (*BodyCompression) Method ¶
func (rcv *BodyCompression) Method() BodyCompressionMethod
/ Indicates the way the record batch body was compressed
func (*BodyCompression) MutateCodec ¶
func (rcv *BodyCompression) MutateCodec(n CompressionType) bool
/ Compressor library
func (*BodyCompression) MutateMethod ¶
func (rcv *BodyCompression) MutateMethod(n BodyCompressionMethod) bool
/ Indicates the way the record batch body was compressed
func (*BodyCompression) Table ¶
func (rcv *BodyCompression) Table() flatbuffers.Table
type BodyCompressionMethod ¶
type BodyCompressionMethod int8
/ Provided for forward compatibility in case we need to support different / strategies for compressing the IPC message body (like whole-body / compression rather than buffer-level) in the future
const ( /// Each constituent buffer is first compressed with the indicated /// compressor, and then written with the uncompressed length in the first 8 /// bytes as a 64-bit little-endian signed integer followed by the compressed /// buffer bytes (and then padding as required by the protocol). The /// uncompressed length may be set to -1 to indicate that the data that /// follows is not compressed, which can be useful for cases where /// compression does not yield appreciable savings. BodyCompressionMethodBUFFER BodyCompressionMethod = 0 )
func (BodyCompressionMethod) String ¶
func (v BodyCompressionMethod) String() string
type Bool ¶
type Bool struct {
// contains filtered or unexported fields
}
func GetRootAsBool ¶
func GetRootAsBool(buf []byte, offset flatbuffers.UOffsetT) *Bool
func (*Bool) Table ¶
func (rcv *Bool) Table() flatbuffers.Table
type Buffer ¶
type Buffer struct {
// contains filtered or unexported fields
}
/ ---------------------------------------------------------------------- / A Buffer represents a single contiguous memory segment
func (*Buffer) Length ¶
/ The absolute length (in bytes) of the memory buffer. The memory is found / from offset (inclusive) to offset + length (non-inclusive). When building / messages using the encapsulated IPC message, padding bytes may be written / after a buffer, but such padding bytes do not need to be accounted for in / the size here.
func (*Buffer) MutateLength ¶
/ The absolute length (in bytes) of the memory buffer. The memory is found / from offset (inclusive) to offset + length (non-inclusive). When building / messages using the encapsulated IPC message, padding bytes may be written / after a buffer, but such padding bytes do not need to be accounted for in / the size here.
func (*Buffer) MutateOffset ¶
/ The relative offset into the shared memory page where the bytes for this / buffer starts
func (*Buffer) Offset ¶
/ The relative offset into the shared memory page where the bytes for this / buffer starts
func (*Buffer) Table ¶
func (rcv *Buffer) Table() flatbuffers.Table
type CompressionType ¶
type CompressionType int8
const ( CompressionTypeLZ4_FRAME CompressionType = 0 CompressionTypeZSTD CompressionType = 1 )
func (CompressionType) String ¶
func (v CompressionType) String() string
type Date ¶
type Date struct {
// contains filtered or unexported fields
}
/ Date is either a 32-bit or 64-bit signed integer type representing an / elapsed time since UNIX epoch (1970-01-01), stored in either of two units: / / * Milliseconds (64 bits) indicating UNIX time elapsed since the epoch (no / leap seconds), where the values are evenly divisible by 86400000 / * Days (32 bits) since the UNIX epoch
func GetRootAsDate ¶
func GetRootAsDate(buf []byte, offset flatbuffers.UOffsetT) *Date
func (*Date) MutateUnit ¶
func (*Date) Table ¶
func (rcv *Date) Table() flatbuffers.Table
type Decimal ¶
type Decimal struct {
// contains filtered or unexported fields
}
/ Exact decimal value represented as an integer value in two's / complement. Currently only 128-bit (16-byte) and 256-bit (32-byte) integers / are used. The representation uses the endianness indicated / in the Schema.
func GetRootAsDecimal ¶
func GetRootAsDecimal(buf []byte, offset flatbuffers.UOffsetT) *Decimal
func (*Decimal) BitWidth ¶
/ Number of bits per value. The only accepted widths are 128 and 256. / We use bitWidth for consistency with Int::bitWidth.
func (*Decimal) MutateBitWidth ¶
/ Number of bits per value. The only accepted widths are 128 and 256. / We use bitWidth for consistency with Int::bitWidth.
func (*Decimal) MutatePrecision ¶
/ Total number of decimal digits
func (*Decimal) MutateScale ¶
/ Number of digits after the decimal point "."
func (*Decimal) Table ¶
func (rcv *Decimal) Table() flatbuffers.Table
type DictionaryBatch ¶
type DictionaryBatch struct {
// contains filtered or unexported fields
}
/ For sending dictionary encoding information. Any Field can be / dictionary-encoded, but in this case none of its children may be / dictionary-encoded. / There is one vector / column per dictionary, but that vector / column / may be spread across multiple dictionary batches by using the isDelta / flag
func GetRootAsDictionaryBatch ¶
func GetRootAsDictionaryBatch(buf []byte, offset flatbuffers.UOffsetT) *DictionaryBatch
func (*DictionaryBatch) Data ¶
func (rcv *DictionaryBatch) Data(obj *RecordBatch) *RecordBatch
func (*DictionaryBatch) Id ¶
func (rcv *DictionaryBatch) Id() int64
func (*DictionaryBatch) Init ¶
func (rcv *DictionaryBatch) Init(buf []byte, i flatbuffers.UOffsetT)
func (*DictionaryBatch) IsDelta ¶
func (rcv *DictionaryBatch) IsDelta() bool
/ If isDelta is true the values in the dictionary are to be appended to a / dictionary with the indicated id. If isDelta is false this dictionary / should replace the existing dictionary.
func (*DictionaryBatch) MutateId ¶
func (rcv *DictionaryBatch) MutateId(n int64) bool
func (*DictionaryBatch) MutateIsDelta ¶
func (rcv *DictionaryBatch) MutateIsDelta(n bool) bool
/ If isDelta is true the values in the dictionary are to be appended to a / dictionary with the indicated id. If isDelta is false this dictionary / should replace the existing dictionary.
func (*DictionaryBatch) Table ¶
func (rcv *DictionaryBatch) Table() flatbuffers.Table
type DictionaryEncoding ¶
type DictionaryEncoding struct {
// contains filtered or unexported fields
}
func GetRootAsDictionaryEncoding ¶
func GetRootAsDictionaryEncoding(buf []byte, offset flatbuffers.UOffsetT) *DictionaryEncoding
func (*DictionaryEncoding) DictionaryKind ¶
func (rcv *DictionaryEncoding) DictionaryKind() DictionaryKind
func (*DictionaryEncoding) Id ¶
func (rcv *DictionaryEncoding) Id() int64
/ The known dictionary id in the application where this data is used. In / the file or streaming formats, the dictionary ids are found in the / DictionaryBatch messages
func (*DictionaryEncoding) IndexType ¶
func (rcv *DictionaryEncoding) IndexType(obj *Int) *Int
/ The dictionary indices are constrained to be non-negative integers. If / this field is null, the indices must be signed int32. To maximize / cross-language compatibility and performance, implementations are / recommended to prefer signed integer types over unsigned integer types / and to avoid uint64 indices unless they are required by an application.
func (*DictionaryEncoding) Init ¶
func (rcv *DictionaryEncoding) Init(buf []byte, i flatbuffers.UOffsetT)
func (*DictionaryEncoding) IsOrdered ¶
func (rcv *DictionaryEncoding) IsOrdered() bool
/ The dictionary indices are constrained to be non-negative integers. If / this field is null, the indices must be signed int32. To maximize / cross-language compatibility and performance, implementations are / recommended to prefer signed integer types over unsigned integer types / and to avoid uint64 indices unless they are required by an application. / By default, dictionaries are not ordered, or the order does not have / semantic meaning. In some statistical, applications, dictionary-encoding / is used to represent ordered categorical data, and we provide a way to / preserve that metadata here
func (*DictionaryEncoding) MutateDictionaryKind ¶
func (rcv *DictionaryEncoding) MutateDictionaryKind(n DictionaryKind) bool
func (*DictionaryEncoding) MutateId ¶
func (rcv *DictionaryEncoding) MutateId(n int64) bool
/ The known dictionary id in the application where this data is used. In / the file or streaming formats, the dictionary ids are found in the / DictionaryBatch messages
func (*DictionaryEncoding) MutateIsOrdered ¶
func (rcv *DictionaryEncoding) MutateIsOrdered(n bool) bool
/ By default, dictionaries are not ordered, or the order does not have / semantic meaning. In some statistical, applications, dictionary-encoding / is used to represent ordered categorical data, and we provide a way to / preserve that metadata here
func (*DictionaryEncoding) Table ¶
func (rcv *DictionaryEncoding) Table() flatbuffers.Table
type DictionaryKind ¶
type DictionaryKind int16
/ ---------------------------------------------------------------------- / Dictionary encoding metadata / Maintained for forwards compatibility, in the future / Dictionaries might be explicit maps between integers and values / allowing for non-contiguous index values
const (
DictionaryKindDenseArray DictionaryKind = 0
)
func (DictionaryKind) String ¶
func (v DictionaryKind) String() string
type Duration ¶
type Duration struct {
// contains filtered or unexported fields
}
func GetRootAsDuration ¶
func GetRootAsDuration(buf []byte, offset flatbuffers.UOffsetT) *Duration
func (*Duration) MutateUnit ¶
func (*Duration) Table ¶
func (rcv *Duration) Table() flatbuffers.Table
type Endianness ¶
type Endianness int16
/ ---------------------------------------------------------------------- / Endianness of the platform producing the data
const ( EndiannessLittle Endianness = 0 EndiannessBig Endianness = 1 )
func (Endianness) String ¶
func (v Endianness) String() string
type Feature ¶
type Feature int64
/ Represents Arrow Features that might not have full support / within implementations. This is intended to be used in / two scenarios: / 1. A mechanism for readers of Arrow Streams / and files to understand that the stream or file makes / use of a feature that isn't supported or unknown to / the implementation (and therefore can meet the Arrow / forward compatibility guarantees). / 2. A means of negotiating between a client and server / what features a stream is allowed to use. The enums / values here are intented to represent higher level / features, additional details maybe negotiated / with key-value pairs specific to the protocol. / / Enums added to this list should be assigned power-of-two values / to facilitate exchanging and comparing bitmaps for supported / features.
const ( /// Needed to make flatbuffers happy. FeatureUNUSED Feature = 0 /// The stream makes use of multiple full dictionaries with the /// same ID and assumes clients implement dictionary replacement /// correctly. FeatureDICTIONARY_REPLACEMENT Feature = 1 /// The stream makes use of compressed bodies as described /// in Message.fbs. FeatureCOMPRESSED_BODY Feature = 2 )
type Field ¶
type Field struct {
// contains filtered or unexported fields
}
/ ---------------------------------------------------------------------- / A field represents a named column in a record / row batch or child of a / nested type.
func GetRootAsField ¶
func GetRootAsField(buf []byte, offset flatbuffers.UOffsetT) *Field
func (*Field) Children ¶
/ Present only if the field is dictionary encoded. / children apply only to nested data types like Struct, List and Union. For / primitive types children will have length 0.
func (*Field) ChildrenLength ¶
func (*Field) CustomMetadata ¶
/ children apply only to nested data types like Struct, List and Union. For / primitive types children will have length 0. / User-defined metadata
func (*Field) CustomMetadataLength ¶
func (*Field) Dictionary ¶
func (rcv *Field) Dictionary(obj *DictionaryEncoding) *DictionaryEncoding
/ This is the type of the decoded value if the field is dictionary encoded. / Present only if the field is dictionary encoded.
func (*Field) MutateNullable ¶
/ Whether or not this field can contain nulls. Should be true in general.
func (*Field) MutateTypeType ¶
func (*Field) Nullable ¶
/ Name is not required, in i.e. a List / Whether or not this field can contain nulls. Should be true in general.
func (*Field) Table ¶
func (rcv *Field) Table() flatbuffers.Table
type FieldNode ¶
type FieldNode struct {
// contains filtered or unexported fields
}
/ ---------------------------------------------------------------------- / Data structures for describing a table row batch (a collection of / equal-length Arrow arrays) / Metadata about a field at some level of a nested type tree (but not / its children). / / For example, a List<Int16> with values `[[1, 2, 3], null, [4], [5, 6], null]` / would have {length: 5, null_count: 2} for its List node, and {length: 6, / null_count: 0} for its Int16 node, as separate FieldNode structs
func (*FieldNode) Length ¶
/ The number of value slots in the Arrow array at this level of a nested / tree
func (*FieldNode) MutateLength ¶
/ The number of value slots in the Arrow array at this level of a nested / tree
func (*FieldNode) MutateNullCount ¶
/ The number of observed nulls. Fields with null_count == 0 may choose not / to write their physical validity bitmap out as a materialized buffer, / instead setting the length of the bitmap buffer to 0.
func (*FieldNode) NullCount ¶
/ The number of observed nulls. Fields with null_count == 0 may choose not / to write their physical validity bitmap out as a materialized buffer, / instead setting the length of the bitmap buffer to 0.
func (*FieldNode) Table ¶
func (rcv *FieldNode) Table() flatbuffers.Table
type FixedSizeBinary ¶
type FixedSizeBinary struct {
// contains filtered or unexported fields
}
func GetRootAsFixedSizeBinary ¶
func GetRootAsFixedSizeBinary(buf []byte, offset flatbuffers.UOffsetT) *FixedSizeBinary
func (*FixedSizeBinary) ByteWidth ¶
func (rcv *FixedSizeBinary) ByteWidth() int32
/ Number of bytes per value
func (*FixedSizeBinary) Init ¶
func (rcv *FixedSizeBinary) Init(buf []byte, i flatbuffers.UOffsetT)
func (*FixedSizeBinary) MutateByteWidth ¶
func (rcv *FixedSizeBinary) MutateByteWidth(n int32) bool
/ Number of bytes per value
func (*FixedSizeBinary) Table ¶
func (rcv *FixedSizeBinary) Table() flatbuffers.Table
type FixedSizeList ¶
type FixedSizeList struct {
// contains filtered or unexported fields
}
func GetRootAsFixedSizeList ¶
func GetRootAsFixedSizeList(buf []byte, offset flatbuffers.UOffsetT) *FixedSizeList
func (*FixedSizeList) Init ¶
func (rcv *FixedSizeList) Init(buf []byte, i flatbuffers.UOffsetT)
func (*FixedSizeList) ListSize ¶
func (rcv *FixedSizeList) ListSize() int32
/ Number of list items per value
func (*FixedSizeList) MutateListSize ¶
func (rcv *FixedSizeList) MutateListSize(n int32) bool
/ Number of list items per value
func (*FixedSizeList) Table ¶
func (rcv *FixedSizeList) Table() flatbuffers.Table
type FloatingPoint ¶
type FloatingPoint struct {
// contains filtered or unexported fields
}
func GetRootAsFloatingPoint ¶
func GetRootAsFloatingPoint(buf []byte, offset flatbuffers.UOffsetT) *FloatingPoint
func (*FloatingPoint) Init ¶
func (rcv *FloatingPoint) Init(buf []byte, i flatbuffers.UOffsetT)
func (*FloatingPoint) MutatePrecision ¶
func (rcv *FloatingPoint) MutatePrecision(n Precision) bool
func (*FloatingPoint) Precision ¶
func (rcv *FloatingPoint) Precision() Precision
func (*FloatingPoint) Table ¶
func (rcv *FloatingPoint) Table() flatbuffers.Table
type Footer ¶
type Footer struct {
// contains filtered or unexported fields
}
/ ---------------------------------------------------------------------- / Arrow File metadata /
func GetRootAsFooter ¶
func GetRootAsFooter(buf []byte, offset flatbuffers.UOffsetT) *Footer
func (*Footer) CustomMetadata ¶
/ User-defined metadata
func (*Footer) CustomMetadataLength ¶
func (*Footer) DictionariesLength ¶
func (*Footer) MutateVersion ¶
func (rcv *Footer) MutateVersion(n MetadataVersion) bool
func (*Footer) RecordBatchesLength ¶
func (*Footer) Table ¶
func (rcv *Footer) Table() flatbuffers.Table
func (*Footer) Version ¶
func (rcv *Footer) Version() MetadataVersion
type Int ¶
type Int struct {
// contains filtered or unexported fields
}
func GetRootAsInt ¶
func GetRootAsInt(buf []byte, offset flatbuffers.UOffsetT) *Int
func (*Int) MutateBitWidth ¶
func (*Int) MutateIsSigned ¶
func (*Int) Table ¶
func (rcv *Int) Table() flatbuffers.Table
type Interval ¶
type Interval struct {
// contains filtered or unexported fields
}
func GetRootAsInterval ¶
func GetRootAsInterval(buf []byte, offset flatbuffers.UOffsetT) *Interval
func (*Interval) MutateUnit ¶
func (rcv *Interval) MutateUnit(n IntervalUnit) bool
func (*Interval) Table ¶
func (rcv *Interval) Table() flatbuffers.Table
func (*Interval) Unit ¶
func (rcv *Interval) Unit() IntervalUnit
type IntervalUnit ¶
type IntervalUnit int16
const ( IntervalUnitYEAR_MONTH IntervalUnit = 0 IntervalUnitDAY_TIME IntervalUnit = 1 IntervalUnitMONTH_DAY_NANO IntervalUnit = 2 )
func (IntervalUnit) String ¶
func (v IntervalUnit) String() string
type KeyValue ¶
type KeyValue struct {
// contains filtered or unexported fields
}
/ ---------------------------------------------------------------------- / user defined key value pairs to add custom metadata to arrow / key namespacing is the responsibility of the user
func GetRootAsKeyValue ¶
func GetRootAsKeyValue(buf []byte, offset flatbuffers.UOffsetT) *KeyValue
func (*KeyValue) Table ¶
func (rcv *KeyValue) Table() flatbuffers.Table
type LargeBinary ¶
type LargeBinary struct {
// contains filtered or unexported fields
}
/ Same as Binary, but with 64-bit offsets, allowing to represent / extremely large data values.
func GetRootAsLargeBinary ¶
func GetRootAsLargeBinary(buf []byte, offset flatbuffers.UOffsetT) *LargeBinary
func (*LargeBinary) Init ¶
func (rcv *LargeBinary) Init(buf []byte, i flatbuffers.UOffsetT)
func (*LargeBinary) Table ¶
func (rcv *LargeBinary) Table() flatbuffers.Table
type LargeList ¶
type LargeList struct {
// contains filtered or unexported fields
}
/ Same as List, but with 64-bit offsets, allowing to represent / extremely large data values.
func GetRootAsLargeList ¶
func GetRootAsLargeList(buf []byte, offset flatbuffers.UOffsetT) *LargeList
func (*LargeList) Table ¶
func (rcv *LargeList) Table() flatbuffers.Table
type LargeUtf8 ¶
type LargeUtf8 struct {
// contains filtered or unexported fields
}
/ Same as Utf8, but with 64-bit offsets, allowing to represent / extremely large data values.
func GetRootAsLargeUtf8 ¶
func GetRootAsLargeUtf8(buf []byte, offset flatbuffers.UOffsetT) *LargeUtf8
func (*LargeUtf8) Table ¶
func (rcv *LargeUtf8) Table() flatbuffers.Table
type List ¶
type List struct {
// contains filtered or unexported fields
}
func GetRootAsList ¶
func GetRootAsList(buf []byte, offset flatbuffers.UOffsetT) *List
func (*List) Table ¶
func (rcv *List) Table() flatbuffers.Table
type Map ¶
type Map struct {
// contains filtered or unexported fields
}
/ A Map is a logical nested type that is represented as / / List<entries: Struct<key: K, value: V>> / / In this layout, the keys and values are each respectively contiguous. We do / not constrain the key and value types, so the application is responsible / for ensuring that the keys are hashable and unique. Whether the keys are sorted / may be set in the metadata for this field. / / In a field with Map type, the field has a child Struct field, which then / has two children: key type and the second the value type. The names of the / child fields may be respectively "entries", "key", and "value", but this is / not enforced. / / Map / ```text / - child[0] entries: Struct / - child[0] key: K / - child[1] value: V / ``` / Neither the "entries" field nor the "key" field may be nullable. / / The metadata is structured so that Arrow systems without special handling / for Map can make Map an alias for List. The "layout" attribute for the Map / field must have the same contents as a List.
func GetRootAsMap ¶
func GetRootAsMap(buf []byte, offset flatbuffers.UOffsetT) *Map
func (*Map) KeysSorted ¶
/ Set to true if the keys within each value are sorted
func (*Map) MutateKeysSorted ¶
/ Set to true if the keys within each value are sorted
func (*Map) Table ¶
func (rcv *Map) Table() flatbuffers.Table
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
func GetRootAsMessage ¶
func GetRootAsMessage(buf []byte, offset flatbuffers.UOffsetT) *Message
func (*Message) BodyLength ¶
func (*Message) CustomMetadataLength ¶
func (*Message) HeaderType ¶
func (rcv *Message) HeaderType() MessageHeader
func (*Message) MutateBodyLength ¶
func (*Message) MutateHeaderType ¶
func (rcv *Message) MutateHeaderType(n MessageHeader) bool
func (*Message) MutateVersion ¶
func (rcv *Message) MutateVersion(n MetadataVersion) bool
func (*Message) Table ¶
func (rcv *Message) Table() flatbuffers.Table
func (*Message) Version ¶
func (rcv *Message) Version() MetadataVersion
type MessageHeader ¶
type MessageHeader byte
/ ---------------------------------------------------------------------- / The root Message type / This union enables us to easily send different message types without / redundant storage, and in the future we can easily add new message types. / / Arrow implementations do not need to implement all of the message types, / which may include experimental metadata types. For maximum compatibility, / it is best to send data using RecordBatch
const ( MessageHeaderNONE MessageHeader = 0 MessageHeaderSchema MessageHeader = 1 MessageHeaderDictionaryBatch MessageHeader = 2 MessageHeaderRecordBatch MessageHeader = 3 MessageHeaderTensor MessageHeader = 4 MessageHeaderSparseTensor MessageHeader = 5 )
func (MessageHeader) String ¶
func (v MessageHeader) String() string
type MetadataVersion ¶
type MetadataVersion int16
const ( /// 0.1.0 (October 2016). MetadataVersionV1 MetadataVersion = 0 /// 0.2.0 (February 2017). Non-backwards compatible with V1. MetadataVersionV2 MetadataVersion = 1 /// 0.3.0 -> 0.7.1 (May - December 2017). Non-backwards compatible with V2. MetadataVersionV3 MetadataVersion = 2 /// >= 0.8.0 (December 2017). Non-backwards compatible with V3. MetadataVersionV4 MetadataVersion = 3 /// >= 1.0.0 (July 2020. Backwards compatible with V4 (V5 readers can read V4 /// metadata and IPC messages). Implementations are recommended to provide a /// V4 compatibility mode with V5 format changes disabled. /// /// Incompatible changes between V4 and V5: /// - Union buffer layout has changed. In V5, Unions don't have a validity /// bitmap buffer. MetadataVersionV5 MetadataVersion = 4 )
func (MetadataVersion) String ¶
func (v MetadataVersion) String() string
type Null ¶
type Null struct {
// contains filtered or unexported fields
}
/ These are stored in the flatbuffer in the Type union below
func GetRootAsNull ¶
func GetRootAsNull(buf []byte, offset flatbuffers.UOffsetT) *Null
func (*Null) Table ¶
func (rcv *Null) Table() flatbuffers.Table
type RecordBatch ¶
type RecordBatch struct {
// contains filtered or unexported fields
}
/ A data header describing the shared memory layout of a "record" or "row" / batch. Some systems call this a "row batch" internally and others a "record / batch".
func GetRootAsRecordBatch ¶
func GetRootAsRecordBatch(buf []byte, offset flatbuffers.UOffsetT) *RecordBatch
func (*RecordBatch) Buffers ¶
func (rcv *RecordBatch) Buffers(obj *Buffer, j int) bool
/ Nodes correspond to the pre-ordered flattened logical schema / Buffers correspond to the pre-ordered flattened buffer tree / / The number of buffers appended to this list depends on the schema. For / example, most primitive arrays will have 2 buffers, 1 for the validity / bitmap and 1 for the values. For struct arrays, there will only be a / single buffer for the validity (nulls) bitmap
func (*RecordBatch) BuffersLength ¶
func (rcv *RecordBatch) BuffersLength() int
func (*RecordBatch) Compression ¶
func (rcv *RecordBatch) Compression(obj *BodyCompression) *BodyCompression
/ Buffers correspond to the pre-ordered flattened buffer tree / / The number of buffers appended to this list depends on the schema. For / example, most primitive arrays will have 2 buffers, 1 for the validity / bitmap and 1 for the values. For struct arrays, there will only be a / single buffer for the validity (nulls) bitmap / Optional compression of the message body
func (*RecordBatch) Init ¶
func (rcv *RecordBatch) Init(buf []byte, i flatbuffers.UOffsetT)
func (*RecordBatch) Length ¶
func (rcv *RecordBatch) Length() int64
/ number of records / rows. The arrays in the batch should all have this / length
func (*RecordBatch) MutateLength ¶
func (rcv *RecordBatch) MutateLength(n int64) bool
/ number of records / rows. The arrays in the batch should all have this / length
func (*RecordBatch) Nodes ¶
func (rcv *RecordBatch) Nodes(obj *FieldNode, j int) bool
/ Nodes correspond to the pre-ordered flattened logical schema
func (*RecordBatch) NodesLength ¶
func (rcv *RecordBatch) NodesLength() int
func (*RecordBatch) Table ¶
func (rcv *RecordBatch) Table() flatbuffers.Table
type Schema ¶
type Schema struct {
// contains filtered or unexported fields
}
/ ---------------------------------------------------------------------- / A Schema describes the columns in a row batch
func GetRootAsSchema ¶
func GetRootAsSchema(buf []byte, offset flatbuffers.UOffsetT) *Schema
func (*Schema) CustomMetadataLength ¶
func (*Schema) Endianness ¶
func (rcv *Schema) Endianness() Endianness
/ endianness of the buffer / it is Little Endian by default / if endianness doesn't match the underlying system then the vectors need to be converted
func (*Schema) FeaturesLength ¶
func (*Schema) FieldsLength ¶
func (*Schema) MutateEndianness ¶
func (rcv *Schema) MutateEndianness(n Endianness) bool
/ endianness of the buffer / it is Little Endian by default / if endianness doesn't match the underlying system then the vectors need to be converted
func (*Schema) MutateFeatures ¶
/ Features used in the stream/file.
func (*Schema) Table ¶
func (rcv *Schema) Table() flatbuffers.Table
type SparseMatrixCompressedAxis ¶
type SparseMatrixCompressedAxis int16
const ( SparseMatrixCompressedAxisRow SparseMatrixCompressedAxis = 0 SparseMatrixCompressedAxisColumn SparseMatrixCompressedAxis = 1 )
func (SparseMatrixCompressedAxis) String ¶
func (v SparseMatrixCompressedAxis) String() string
type SparseMatrixIndexCSR ¶
type SparseMatrixIndexCSR struct {
// contains filtered or unexported fields
}
/ Compressed Sparse Row format, that is matrix-specific.
func GetRootAsSparseMatrixIndexCSR ¶
func GetRootAsSparseMatrixIndexCSR(buf []byte, offset flatbuffers.UOffsetT) *SparseMatrixIndexCSR
func (*SparseMatrixIndexCSR) IndicesBuffer ¶
func (rcv *SparseMatrixIndexCSR) IndicesBuffer(obj *Buffer) *Buffer
/ The type of values in indicesBuffer / indicesBuffer stores the location and size of the array that / contains the column indices of the corresponding non-zero values. / The type of index value is long. / / For example, the indices of the above X is: / / indices(X) = [1, 2, 2, 1, 3, 0, 2, 3, 1]. / / Note that the indices are sorted in lexicographical order for each row.
func (*SparseMatrixIndexCSR) IndicesType ¶
func (rcv *SparseMatrixIndexCSR) IndicesType(obj *Int) *Int
/ indptrBuffer stores the location and size of indptr array that / represents the range of the rows. / The i-th row spans from indptr[i] to indptr[i+1] in the data. / The length of this array is 1 + (the number of rows), and the type / of index value is long. / / For example, let X be the following 6x4 matrix: / / X := [[0, 1, 2, 0], / [0, 0, 3, 0], / [0, 4, 0, 5], / [0, 0, 0, 0], / [6, 0, 7, 8], / [0, 9, 0, 0]]. / / The array of non-zero values in X is: / / values(X) = [1, 2, 3, 4, 5, 6, 7, 8, 9]. / / And the indptr of X is: / / indptr(X) = [0, 2, 3, 5, 5, 8, 10]. / The type of values in indicesBuffer
func (*SparseMatrixIndexCSR) IndptrBuffer ¶
func (rcv *SparseMatrixIndexCSR) IndptrBuffer(obj *Buffer) *Buffer
/ The type of values in indptrBuffer / indptrBuffer stores the location and size of indptr array that / represents the range of the rows. / The i-th row spans from indptr[i] to indptr[i+1] in the data. / The length of this array is 1 + (the number of rows), and the type / of index value is long. / / For example, let X be the following 6x4 matrix: / / X := [[0, 1, 2, 0], / [0, 0, 3, 0], / [0, 4, 0, 5], / [0, 0, 0, 0], / [6, 0, 7, 8], / [0, 9, 0, 0]]. / / The array of non-zero values in X is: / / values(X) = [1, 2, 3, 4, 5, 6, 7, 8, 9]. / / And the indptr of X is: / / indptr(X) = [0, 2, 3, 5, 5, 8, 10].
func (*SparseMatrixIndexCSR) IndptrType ¶
func (rcv *SparseMatrixIndexCSR) IndptrType(obj *Int) *Int
/ The type of values in indptrBuffer
func (*SparseMatrixIndexCSR) Init ¶
func (rcv *SparseMatrixIndexCSR) Init(buf []byte, i flatbuffers.UOffsetT)
func (*SparseMatrixIndexCSR) Table ¶
func (rcv *SparseMatrixIndexCSR) Table() flatbuffers.Table
type SparseMatrixIndexCSX ¶
type SparseMatrixIndexCSX struct {
// contains filtered or unexported fields
}
/ Compressed Sparse format, that is matrix-specific.
func GetRootAsSparseMatrixIndexCSX ¶
func GetRootAsSparseMatrixIndexCSX(buf []byte, offset flatbuffers.UOffsetT) *SparseMatrixIndexCSX
func (*SparseMatrixIndexCSX) CompressedAxis ¶
func (rcv *SparseMatrixIndexCSX) CompressedAxis() SparseMatrixCompressedAxis
/ Which axis, row or column, is compressed
func (*SparseMatrixIndexCSX) IndicesBuffer ¶
func (rcv *SparseMatrixIndexCSX) IndicesBuffer(obj *Buffer) *Buffer
/ The type of values in indicesBuffer / indicesBuffer stores the location and size of the array that / contains the column indices of the corresponding non-zero values. / The type of index value is long. / / For example, the indices of the above X is: / ```text / indices(X) = [1, 2, 2, 1, 3, 0, 2, 3, 1]. / ``` / Note that the indices are sorted in lexicographical order for each row.
func (*SparseMatrixIndexCSX) IndicesType ¶
func (rcv *SparseMatrixIndexCSX) IndicesType(obj *Int) *Int
/ indptrBuffer stores the location and size of indptr array that / represents the range of the rows. / The i-th row spans from `indptr[i]` to `indptr[i+1]` in the data. / The length of this array is 1 + (the number of rows), and the type / of index value is long. / / For example, let X be the following 6x4 matrix: / ```text / X := [[0, 1, 2, 0], / [0, 0, 3, 0], / [0, 4, 0, 5], / [0, 0, 0, 0], / [6, 0, 7, 8], / [0, 9, 0, 0]]. / ``` / The array of non-zero values in X is: / ```text / values(X) = [1, 2, 3, 4, 5, 6, 7, 8, 9]. / ``` / And the indptr of X is: / ```text / indptr(X) = [0, 2, 3, 5, 5, 8, 10]. / ``` / The type of values in indicesBuffer
func (*SparseMatrixIndexCSX) IndptrBuffer ¶
func (rcv *SparseMatrixIndexCSX) IndptrBuffer(obj *Buffer) *Buffer
/ The type of values in indptrBuffer / indptrBuffer stores the location and size of indptr array that / represents the range of the rows. / The i-th row spans from `indptr[i]` to `indptr[i+1]` in the data. / The length of this array is 1 + (the number of rows), and the type / of index value is long. / / For example, let X be the following 6x4 matrix: / ```text / X := [[0, 1, 2, 0], / [0, 0, 3, 0], / [0, 4, 0, 5], / [0, 0, 0, 0], / [6, 0, 7, 8], / [0, 9, 0, 0]]. / ``` / The array of non-zero values in X is: / ```text / values(X) = [1, 2, 3, 4, 5, 6, 7, 8, 9]. / ``` / And the indptr of X is: / ```text / indptr(X) = [0, 2, 3, 5, 5, 8, 10]. / ```
func (*SparseMatrixIndexCSX) IndptrType ¶
func (rcv *SparseMatrixIndexCSX) IndptrType(obj *Int) *Int
/ The type of values in indptrBuffer
func (*SparseMatrixIndexCSX) Init ¶
func (rcv *SparseMatrixIndexCSX) Init(buf []byte, i flatbuffers.UOffsetT)
func (*SparseMatrixIndexCSX) MutateCompressedAxis ¶
func (rcv *SparseMatrixIndexCSX) MutateCompressedAxis(n SparseMatrixCompressedAxis) bool
/ Which axis, row or column, is compressed
func (*SparseMatrixIndexCSX) Table ¶
func (rcv *SparseMatrixIndexCSX) Table() flatbuffers.Table
type SparseTensor ¶
type SparseTensor struct {
// contains filtered or unexported fields
}
func GetRootAsSparseTensor ¶
func GetRootAsSparseTensor(buf []byte, offset flatbuffers.UOffsetT) *SparseTensor
func (*SparseTensor) Data ¶
func (rcv *SparseTensor) Data(obj *Buffer) *Buffer
/ Sparse tensor index / The location and size of the tensor's data
func (*SparseTensor) Init ¶
func (rcv *SparseTensor) Init(buf []byte, i flatbuffers.UOffsetT)
func (*SparseTensor) MutateNonZeroLength ¶
func (rcv *SparseTensor) MutateNonZeroLength(n int64) bool
/ The number of non-zero values in a sparse tensor.
func (*SparseTensor) MutateSparseIndexType ¶
func (rcv *SparseTensor) MutateSparseIndexType(n SparseTensorIndex) bool
func (*SparseTensor) MutateTypeType ¶
func (rcv *SparseTensor) MutateTypeType(n Type) bool
func (*SparseTensor) NonZeroLength ¶
func (rcv *SparseTensor) NonZeroLength() int64
/ The dimensions of the tensor, optionally named. / The number of non-zero values in a sparse tensor.
func (*SparseTensor) Shape ¶
func (rcv *SparseTensor) Shape(obj *TensorDim, j int) bool
/ The type of data contained in a value cell. / Currently only fixed-width value types are supported, / no strings or nested types. / The dimensions of the tensor, optionally named.
func (*SparseTensor) ShapeLength ¶
func (rcv *SparseTensor) ShapeLength() int
func (*SparseTensor) SparseIndex ¶
func (rcv *SparseTensor) SparseIndex(obj *flatbuffers.Table) bool
/ Sparse tensor index
func (*SparseTensor) SparseIndexType ¶
func (rcv *SparseTensor) SparseIndexType() SparseTensorIndex
func (*SparseTensor) Table ¶
func (rcv *SparseTensor) Table() flatbuffers.Table
func (*SparseTensor) Type ¶
func (rcv *SparseTensor) Type(obj *flatbuffers.Table) bool
/ The type of data contained in a value cell. / Currently only fixed-width value types are supported, / no strings or nested types.
func (*SparseTensor) TypeType ¶
func (rcv *SparseTensor) TypeType() Type
type SparseTensorIndex ¶
type SparseTensorIndex byte
const ( SparseTensorIndexNONE SparseTensorIndex = 0 SparseTensorIndexSparseTensorIndexCOO SparseTensorIndex = 1 SparseTensorIndexSparseMatrixIndexCSX SparseTensorIndex = 2 SparseTensorIndexSparseTensorIndexCSF SparseTensorIndex = 3 )
func (SparseTensorIndex) String ¶
func (v SparseTensorIndex) String() string
type SparseTensorIndexCOO ¶
type SparseTensorIndexCOO struct {
// contains filtered or unexported fields
}
/ ---------------------------------------------------------------------- / EXPERIMENTAL: Data structures for sparse tensors / Coordinate (COO) format of sparse tensor index. / / COO's index list are represented as a NxM matrix, / where N is the number of non-zero values, / and M is the number of dimensions of a sparse tensor. / / indicesBuffer stores the location and size of the data of this indices / matrix. The value type and the stride of the indices matrix is / specified in indicesType and indicesStrides fields. / / For example, let X be a 2x3x4x5 tensor, and it has the following / 6 non-zero values: / ```text / X[0, 1, 2, 0] := 1 / X[1, 1, 2, 3] := 2 / X[0, 2, 1, 0] := 3 / X[0, 1, 3, 0] := 4 / X[0, 1, 2, 1] := 5 / X[1, 2, 0, 4] := 6 / ``` / In COO format, the index matrix of X is the following 4x6 matrix: / ```text / [[0, 0, 0, 0, 1, 1], / [1, 1, 1, 2, 1, 2], / [2, 2, 3, 1, 2, 0], / [0, 1, 0, 0, 3, 4]] / ``` / When isCanonical is true, the indices is sorted in lexicographical order / (row-major order), and it does not have duplicated entries. Otherwise, / the indices may not be sorted, or may have duplicated entries.
func GetRootAsSparseTensorIndexCOO ¶
func GetRootAsSparseTensorIndexCOO(buf []byte, offset flatbuffers.UOffsetT) *SparseTensorIndexCOO
func (*SparseTensorIndexCOO) IndicesBuffer ¶
func (rcv *SparseTensorIndexCOO) IndicesBuffer(obj *Buffer) *Buffer
/ The location and size of the indices matrix's data
func (*SparseTensorIndexCOO) IndicesStrides ¶
func (rcv *SparseTensorIndexCOO) IndicesStrides(j int) int64
/ The type of values in indicesBuffer / Non-negative byte offsets to advance one value cell along each dimension / If omitted, default to row-major order (C-like).
func (*SparseTensorIndexCOO) IndicesStridesLength ¶
func (rcv *SparseTensorIndexCOO) IndicesStridesLength() int
func (*SparseTensorIndexCOO) IndicesType ¶
func (rcv *SparseTensorIndexCOO) IndicesType(obj *Int) *Int
/ The type of values in indicesBuffer
func (*SparseTensorIndexCOO) Init ¶
func (rcv *SparseTensorIndexCOO) Init(buf []byte, i flatbuffers.UOffsetT)
func (*SparseTensorIndexCOO) IsCanonical ¶
func (rcv *SparseTensorIndexCOO) IsCanonical() bool
/ The location and size of the indices matrix's data / This flag is true if and only if the indices matrix is sorted in / row-major order, and does not have duplicated entries. / This sort order is the same as of Tensorflow's SparseTensor, / but it is inverse order of SciPy's canonical coo_matrix / (SciPy employs column-major order for its coo_matrix).
func (*SparseTensorIndexCOO) MutateIndicesStrides ¶
func (rcv *SparseTensorIndexCOO) MutateIndicesStrides(j int, n int64) bool
/ Non-negative byte offsets to advance one value cell along each dimension / If omitted, default to row-major order (C-like).
func (*SparseTensorIndexCOO) MutateIsCanonical ¶
func (rcv *SparseTensorIndexCOO) MutateIsCanonical(n bool) bool
/ This flag is true if and only if the indices matrix is sorted in / row-major order, and does not have duplicated entries. / This sort order is the same as of Tensorflow's SparseTensor, / but it is inverse order of SciPy's canonical coo_matrix / (SciPy employs column-major order for its coo_matrix).
func (*SparseTensorIndexCOO) Table ¶
func (rcv *SparseTensorIndexCOO) Table() flatbuffers.Table
type SparseTensorIndexCSF ¶
type SparseTensorIndexCSF struct {
// contains filtered or unexported fields
}
/ Compressed Sparse Fiber (CSF) sparse tensor index.
func GetRootAsSparseTensorIndexCSF ¶
func GetRootAsSparseTensorIndexCSF(buf []byte, offset flatbuffers.UOffsetT) *SparseTensorIndexCSF
func (*SparseTensorIndexCSF) AxisOrder ¶
func (rcv *SparseTensorIndexCSF) AxisOrder(j int) int32
/ indicesBuffers stores values of nodes. / Each tensor dimension corresponds to a buffer in indicesBuffers. / For example, the indicesBuffers for the above X is: / ```text / indicesBuffer(X) = [ / [0, 1], / [0, 1, 1], / [0, 0, 1, 1], / [1, 2, 0, 2, 0, 0, 1, 2] / ]. / ``` / axisOrder stores the sequence in which dimensions were traversed to / produce the prefix tree. / For example, the axisOrder for the above X is: / ```text / axisOrder(X) = [0, 1, 2, 3]. / ```
func (*SparseTensorIndexCSF) AxisOrderLength ¶
func (rcv *SparseTensorIndexCSF) AxisOrderLength() int
func (*SparseTensorIndexCSF) IndicesBuffers ¶
func (rcv *SparseTensorIndexCSF) IndicesBuffers(obj *Buffer, j int) bool
/ The type of values in indicesBuffers / indicesBuffers stores values of nodes. / Each tensor dimension corresponds to a buffer in indicesBuffers. / For example, the indicesBuffers for the above X is: / ```text / indicesBuffer(X) = [ / [0, 1], / [0, 1, 1], / [0, 0, 1, 1], / [1, 2, 0, 2, 0, 0, 1, 2] / ]. / ```
func (*SparseTensorIndexCSF) IndicesBuffersLength ¶
func (rcv *SparseTensorIndexCSF) IndicesBuffersLength() int
func (*SparseTensorIndexCSF) IndicesType ¶
func (rcv *SparseTensorIndexCSF) IndicesType(obj *Int) *Int
/ indptrBuffers stores the sparsity structure. / Each two consecutive dimensions in a tensor correspond to a buffer in / indptrBuffers. A pair of consecutive values at `indptrBuffers[dim][i]` / and `indptrBuffers[dim][i + 1]` signify a range of nodes in / `indicesBuffers[dim + 1]` who are children of `indicesBuffers[dim][i]` node. / / For example, the indptrBuffers for the above X is: / ```text / indptrBuffer(X) = [ / [0, 2, 3], / [0, 1, 3, 4], / [0, 2, 4, 5, 8] / ]. / ``` / The type of values in indicesBuffers
func (*SparseTensorIndexCSF) IndptrBuffers ¶
func (rcv *SparseTensorIndexCSF) IndptrBuffers(obj *Buffer, j int) bool
/ CSF is a generalization of compressed sparse row (CSR) index. / See [smith2017knl](http://shaden.io/pub-files/smith2017knl.pdf) / / CSF index recursively compresses each dimension of a tensor into a set / of prefix trees. Each path from a root to leaf forms one tensor / non-zero index. CSF is implemented with two arrays of buffers and one / arrays of integers. / / For example, let X be a 2x3x4x5 tensor and let it have the following / 8 non-zero values: / ```text / X[0, 0, 0, 1] := 1 / X[0, 0, 0, 2] := 2 / X[0, 1, 0, 0] := 3 / X[0, 1, 0, 2] := 4 / X[0, 1, 1, 0] := 5 / X[1, 1, 1, 0] := 6 / X[1, 1, 1, 1] := 7 / X[1, 1, 1, 2] := 8 / ``` / As a prefix tree this would be represented as: / ```text / 0 1 / / \ | / 0 1 1 / / / \ | / 0 0 1 1 / /| /| | /| | / 1 2 0 2 0 0 1 2 / ``` / The type of values in indptrBuffers / indptrBuffers stores the sparsity structure. / Each two consecutive dimensions in a tensor correspond to a buffer in / indptrBuffers. A pair of consecutive values at `indptrBuffers[dim][i]` / and `indptrBuffers[dim][i + 1]` signify a range of nodes in / `indicesBuffers[dim + 1]` who are children of `indicesBuffers[dim][i]` node. / / For example, the indptrBuffers for the above X is: / ```text / indptrBuffer(X) = [ / [0, 2, 3], / [0, 1, 3, 4], / [0, 2, 4, 5, 8] / ]. / ```
func (*SparseTensorIndexCSF) IndptrBuffersLength ¶
func (rcv *SparseTensorIndexCSF) IndptrBuffersLength() int
func (*SparseTensorIndexCSF) IndptrType ¶
func (rcv *SparseTensorIndexCSF) IndptrType(obj *Int) *Int
/ CSF is a generalization of compressed sparse row (CSR) index. / See [smith2017knl](http://shaden.io/pub-files/smith2017knl.pdf) / / CSF index recursively compresses each dimension of a tensor into a set / of prefix trees. Each path from a root to leaf forms one tensor / non-zero index. CSF is implemented with two arrays of buffers and one / arrays of integers. / / For example, let X be a 2x3x4x5 tensor and let it have the following / 8 non-zero values: / ```text / X[0, 0, 0, 1] := 1 / X[0, 0, 0, 2] := 2 / X[0, 1, 0, 0] := 3 / X[0, 1, 0, 2] := 4 / X[0, 1, 1, 0] := 5 / X[1, 1, 1, 0] := 6 / X[1, 1, 1, 1] := 7 / X[1, 1, 1, 2] := 8 / ``` / As a prefix tree this would be represented as: / ```text / 0 1 / / \ | / 0 1 1 / / / \ | / 0 0 1 1 / /| /| | /| | / 1 2 0 2 0 0 1 2 / ``` / The type of values in indptrBuffers
func (*SparseTensorIndexCSF) Init ¶
func (rcv *SparseTensorIndexCSF) Init(buf []byte, i flatbuffers.UOffsetT)
func (*SparseTensorIndexCSF) MutateAxisOrder ¶
func (rcv *SparseTensorIndexCSF) MutateAxisOrder(j int, n int32) bool
/ axisOrder stores the sequence in which dimensions were traversed to / produce the prefix tree. / For example, the axisOrder for the above X is: / ```text / axisOrder(X) = [0, 1, 2, 3]. / ```
func (*SparseTensorIndexCSF) Table ¶
func (rcv *SparseTensorIndexCSF) Table() flatbuffers.Table
type Struct_ ¶
type Struct_ struct {
// contains filtered or unexported fields
}
/ A Struct_ in the flatbuffer metadata is the same as an Arrow Struct / (according to the physical memory layout). We used Struct_ here as / Struct is a reserved word in Flatbuffers
func GetRootAsStruct_ ¶
func GetRootAsStruct_(buf []byte, offset flatbuffers.UOffsetT) *Struct_
func (*Struct_) Table ¶
func (rcv *Struct_) Table() flatbuffers.Table
type Tensor ¶
type Tensor struct {
// contains filtered or unexported fields
}
func GetRootAsTensor ¶
func GetRootAsTensor(buf []byte, offset flatbuffers.UOffsetT) *Tensor
func (*Tensor) MutateStrides ¶
/ Non-negative byte offsets to advance one value cell along each dimension / If omitted, default to row-major order (C-like).
func (*Tensor) MutateTypeType ¶
func (*Tensor) Shape ¶
/ The type of data contained in a value cell. Currently only fixed-width / value types are supported, no strings or nested types / The dimensions of the tensor, optionally named
func (*Tensor) ShapeLength ¶
func (*Tensor) Strides ¶
/ The dimensions of the tensor, optionally named / Non-negative byte offsets to advance one value cell along each dimension / If omitted, default to row-major order (C-like).
func (*Tensor) StridesLength ¶
func (*Tensor) Table ¶
func (rcv *Tensor) Table() flatbuffers.Table
type TensorDim ¶
type TensorDim struct {
// contains filtered or unexported fields
}
/ ---------------------------------------------------------------------- / Data structures for dense tensors / Shape data for a single axis in a tensor
func GetRootAsTensorDim ¶
func GetRootAsTensorDim(buf []byte, offset flatbuffers.UOffsetT) *TensorDim
func (*TensorDim) Table ¶
func (rcv *TensorDim) Table() flatbuffers.Table
type Time ¶
type Time struct {
// contains filtered or unexported fields
}
/ Time is either a 32-bit or 64-bit signed integer type representing an / elapsed time since midnight, stored in either of four units: seconds, / milliseconds, microseconds or nanoseconds. / / The integer `bitWidth` depends on the `unit` and must be one of the following: / * SECOND and MILLISECOND: 32 bits / * MICROSECOND and NANOSECOND: 64 bits / / The allowed values are between 0 (inclusive) and 86400 (=24*60*60) seconds / (exclusive), adjusted for the time unit (for example, up to 86400000 / exclusive for the MILLISECOND unit). / This definition doesn't allow for leap seconds. Time values from / measurements with leap seconds will need to be corrected when ingesting / into Arrow (for example by replacing the value 86400 with 86399).
func GetRootAsTime ¶
func GetRootAsTime(buf []byte, offset flatbuffers.UOffsetT) *Time
func (*Time) MutateBitWidth ¶
func (*Time) MutateUnit ¶
func (*Time) Table ¶
func (rcv *Time) Table() flatbuffers.Table
type Timestamp ¶
type Timestamp struct {
// contains filtered or unexported fields
}
/ Timestamp is a 64-bit signed integer representing an elapsed time since a / fixed epoch, stored in either of four units: seconds, milliseconds, / microseconds or nanoseconds, and is optionally annotated with a timezone. / / Timestamp values do not include any leap seconds (in other words, all / days are considered 86400 seconds long). / / Timestamps with a non-empty timezone / ------------------------------------ / / If a Timestamp column has a non-empty timezone value, its epoch is / 1970-01-01 00:00:00 (January 1st 1970, midnight) in the *UTC* timezone / (the Unix epoch), regardless of the Timestamp's own timezone. / / Therefore, timestamp values with a non-empty timezone correspond to / physical points in time together with some additional information about / how the data was obtained and/or how to display it (the timezone). / / For example, the timestamp value 0 with the timezone string "Europe/Paris" / corresponds to "January 1st 1970, 00h00" in the UTC timezone, but the / application may prefer to display it as "January 1st 1970, 01h00" in / the Europe/Paris timezone (which is the same physical point in time). / / One consequence is that timestamp values with a non-empty timezone / can be compared and ordered directly, since they all share the same / well-known point of reference (the Unix epoch). / / Timestamps with an unset / empty timezone / ----------------------------------------- / / If a Timestamp column has no timezone value, its epoch is / 1970-01-01 00:00:00 (January 1st 1970, midnight) in an *unknown* timezone. / / Therefore, timestamp values without a timezone cannot be meaningfully / interpreted as physical points in time, but only as calendar / clock / indications ("wall clock time") in an unspecified timezone. / / For example, the timestamp value 0 with an empty timezone string / corresponds to "January 1st 1970, 00h00" in an unknown timezone: there / is not enough information to interpret it as a well-defined physical / point in time. / / One consequence is that timestamp values without a timezone cannot / be reliably compared or ordered, since they may have different points of / reference. In particular, it is *not* possible to interpret an unset / or empty timezone as the same as "UTC". / / Conversion between timezones / ---------------------------- / / If a Timestamp column has a non-empty timezone, changing the timezone / to a different non-empty value is a metadata-only operation: / the timestamp values need not change as their point of reference remains / the same (the Unix epoch). / / However, if a Timestamp column has no timezone value, changing it to a / non-empty value requires to think about the desired semantics. / One possibility is to assume that the original timestamp values are / relative to the epoch of the timezone being set; timestamp values should / then adjusted to the Unix epoch (for example, changing the timezone from / empty to "Europe/Paris" would require converting the timestamp values / from "Europe/Paris" to "UTC", which seems counter-intuitive but is / nevertheless correct). / / Guidelines for encoding data from external libraries / ---------------------------------------------------- / / Date & time libraries often have multiple different data types for temporal / data. In order to ease interoperability between different implementations the / Arrow project has some recommendations for encoding these types into a Timestamp / column. / / An "instant" represents a physical point in time that has no relevant timezone / (for example, astronomical data). To encode an instant, use a Timestamp with / the timezone string set to "UTC", and make sure the Timestamp values / are relative to the UTC epoch (January 1st 1970, midnight). / / A "zoned date-time" represents a physical point in time annotated with an / informative timezone (for example, the timezone in which the data was / recorded). To encode a zoned date-time, use a Timestamp with the timezone / string set to the name of the timezone, and make sure the Timestamp values / are relative to the UTC epoch (January 1st 1970, midnight). / / (There is some ambiguity between an instant and a zoned date-time with the / UTC timezone. Both of these are stored the same in Arrow. Typically, / this distinction does not matter. If it does, then an application should / use custom metadata or an extension type to distinguish between the two cases.) / / An "offset date-time" represents a physical point in time combined with an / explicit offset from UTC. To encode an offset date-time, use a Timestamp / with the timezone string set to the numeric timezone offset string / (e.g. "+03:00"), and make sure the Timestamp values are relative to / the UTC epoch (January 1st 1970, midnight). / / A "naive date-time" (also called "local date-time" in some libraries) / represents a wall clock time combined with a calendar date, but with / no indication of how to map this information to a physical point in time. / Naive date-times must be handled with care because of this missing / information, and also because daylight saving time (DST) may make / some values ambiguous or non-existent. A naive date-time may be / stored as a struct with Date and Time fields. However, it may also be / encoded into a Timestamp column with an empty timezone. The timestamp / values should be computed "as if" the timezone of the date-time values / was UTC; for example, the naive date-time "January 1st 1970, 00h00" would / be encoded as timestamp value 0.
func GetRootAsTimestamp ¶
func GetRootAsTimestamp(buf []byte, offset flatbuffers.UOffsetT) *Timestamp
func (*Timestamp) MutateUnit ¶
func (*Timestamp) Table ¶
func (rcv *Timestamp) Table() flatbuffers.Table
func (*Timestamp) Timezone ¶
/ The timezone is an optional string indicating the name of a timezone, / one of: / / * As used in the Olson timezone database (the "tz database" or / "tzdata"), such as "America/New_York". / * An absolute timezone offset of the form "+XX:XX" or "-XX:XX", / such as "+07:30". / / Whether a timezone string is present indicates different semantics about / the data (see above).
type Type ¶
type Type byte
/ ---------------------------------------------------------------------- / Top-level Type value, enabling extensible type-specific metadata. We can / add new logical types to Type without breaking backwards compatibility
const ( TypeNONE Type = 0 TypeNull Type = 1 TypeInt Type = 2 TypeFloatingPoint Type = 3 TypeBinary Type = 4 TypeUtf8 Type = 5 TypeBool Type = 6 TypeDecimal Type = 7 TypeDate Type = 8 TypeTime Type = 9 TypeTimestamp Type = 10 TypeInterval Type = 11 TypeList Type = 12 TypeStruct_ Type = 13 TypeUnion Type = 14 TypeFixedSizeBinary Type = 15 TypeFixedSizeList Type = 16 TypeMap Type = 17 TypeDuration Type = 18 TypeLargeBinary Type = 19 TypeLargeUtf8 Type = 20 TypeLargeList Type = 21 )
type Union ¶
type Union struct {
// contains filtered or unexported fields
}
/ A union is a complex type with children in Field / By default ids in the type vector refer to the offsets in the children / optionally typeIds provides an indirection between the child offset and the type id / for each child `typeIds[offset]` is the id used in the type vector
func GetRootAsUnion ¶
func GetRootAsUnion(buf []byte, offset flatbuffers.UOffsetT) *Union
func (*Union) MutateMode ¶
func (*Union) Table ¶
func (rcv *Union) Table() flatbuffers.Table
func (*Union) TypeIdsLength ¶
type Utf8 ¶
type Utf8 struct {
// contains filtered or unexported fields
}
/ Unicode with UTF-8 encoding
func GetRootAsUtf8 ¶
func GetRootAsUtf8(buf []byte, offset flatbuffers.UOffsetT) *Utf8
func (*Utf8) Table ¶
func (rcv *Utf8) Table() flatbuffers.Table
Source Files ¶
- Binary.go
- Block.go
- BodyCompression.go
- BodyCompressionMethod.go
- Bool.go
- Buffer.go
- CompressionType.go
- Date.go
- DateUnit.go
- Decimal.go
- DictionaryBatch.go
- DictionaryEncoding.go
- DictionaryKind.go
- Duration.go
- Endianness.go
- Feature.go
- Field.go
- FieldNode.go
- FixedSizeBinary.go
- FixedSizeList.go
- FloatingPoint.go
- Footer.go
- Int.go
- Interval.go
- IntervalUnit.go
- KeyValue.go
- LargeBinary.go
- LargeList.go
- LargeUtf8.go
- List.go
- Map.go
- Message.go
- MessageHeader.go
- MetadataVersion.go
- Null.go
- Precision.go
- RecordBatch.go
- Schema.go
- SparseMatrixCompressedAxis.go
- SparseMatrixIndexCSR.go
- SparseMatrixIndexCSX.go
- SparseTensor.go
- SparseTensorIndex.go
- SparseTensorIndexCOO.go
- SparseTensorIndexCSF.go
- Struct_.go
- Tensor.go
- TensorDim.go
- Time.go
- TimeUnit.go
- Timestamp.go
- Type.go
- Union.go
- UnionMode.go
- Utf8.go