package flatbuf

import "github.com/apache/arrow/go/v11/arrow/internal/flatbuf"

Index

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",
	TypeRunEndEncoded:   "RunEndEncoded",
}
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,
	"RunEndEncoded":   TypeRunEndEncoded,
}
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 FieldStart 

func FieldStart(builder *flatbuffers.Builder)

/ User-defined metadata

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 FooterStart 

func FooterStart(builder *flatbuffers.Builder)

/ User-defined metadata

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 RunEndEncodedEnd 

func RunEndEncodedEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func RunEndEncodedStart 

func RunEndEncodedStart(builder *flatbuffers.Builder)

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) Init 

func (rcv *Binary) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Binary) Table 

func (rcv *Binary) Table() flatbuffers.Table

type Block 

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

func (*Block) BodyLength 

func (rcv *Block) BodyLength() int64

/ Length of the data (this is aligned so there can be a gap between this and / the metadata).

func (*Block) Init 

func (rcv *Block) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Block) MetaDataLength 

func (rcv *Block) MetaDataLength() int32

/ Length of the metadata

func (*Block) MutateBodyLength 

func (rcv *Block) MutateBodyLength(n int64) bool

/ Length of the data (this is aligned so there can be a gap between this and / the metadata).

func (*Block) MutateMetaDataLength 

func (rcv *Block) MutateMetaDataLength(n int32) bool

/ Length of the metadata

func (*Block) MutateOffset 

func (rcv *Block) MutateOffset(n int64) bool

/ Index to the start of the RecordBlock (note this is past the Message header)

func (*Block) Offset 

func (rcv *Block) Offset() int64

/ 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. / For LZ4_FRAME, each compressed buffer must consist of a single frame.

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. / For LZ4_FRAME, each compressed buffer must consist of a single frame.

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) Init 

func (rcv *Bool) Init(buf []byte, i flatbuffers.UOffsetT)

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) Init 

func (rcv *Buffer) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Buffer) Length 

func (rcv *Buffer) Length() int64

/ 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 

func (rcv *Buffer) MutateLength(n int64) bool

/ 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 

func (rcv *Buffer) MutateOffset(n int64) bool

/ The relative offset into the shared memory page where the bytes for this / buffer starts

func (*Buffer) Offset 

func (rcv *Buffer) Offset() int64

/ 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) Init 

func (rcv *Date) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Date) MutateUnit 

func (rcv *Date) MutateUnit(n DateUnit) bool

func (*Date) Table 

func (rcv *Date) Table() flatbuffers.Table

func (*Date) Unit 

func (rcv *Date) Unit() DateUnit

type DateUnit 

type DateUnit int16
const (
	DateUnitDAY         DateUnit = 0
	DateUnitMILLISECOND DateUnit = 1
)

func (DateUnit) String 

func (v DateUnit) String() string

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 

func (rcv *Decimal) BitWidth() int32

/ Number of bits per value. The only accepted widths are 128 and 256. / We use bitWidth for consistency with Int::bitWidth.

func (*Decimal) Init 

func (rcv *Decimal) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Decimal) MutateBitWidth 

func (rcv *Decimal) MutateBitWidth(n int32) bool

/ Number of bits per value. The only accepted widths are 128 and 256. / We use bitWidth for consistency with Int::bitWidth.

func (*Decimal) MutatePrecision 

func (rcv *Decimal) MutatePrecision(n int32) bool

/ Total number of decimal digits

func (*Decimal) MutateScale 

func (rcv *Decimal) MutateScale(n int32) bool

/ Number of digits after the decimal point "."

func (*Decimal) Precision 

func (rcv *Decimal) Precision() int32

/ Total number of decimal digits

func (*Decimal) Scale 

func (rcv *Decimal) Scale() int32

/ 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) Init 

func (rcv *Duration) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Duration) MutateUnit 

func (rcv *Duration) MutateUnit(n TimeUnit) bool

func (*Duration) Table 

func (rcv *Duration) Table() flatbuffers.Table

func (*Duration) Unit 

func (rcv *Duration) Unit() TimeUnit

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
)

func (Feature) String 

func (v Feature) String() string

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 

func (rcv *Field) Children(obj *Field, j int) bool

/ 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 (rcv *Field) ChildrenLength() int

func (*Field) CustomMetadata 

func (rcv *Field) CustomMetadata(obj *KeyValue, j int) bool

/ 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 (rcv *Field) CustomMetadataLength() int

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) Init 

func (rcv *Field) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Field) MutateNullable 

func (rcv *Field) MutateNullable(n bool) bool

/ Whether or not this field can contain nulls. Should be true in general.

func (*Field) MutateTypeType 

func (rcv *Field) MutateTypeType(n Type) bool

func (*Field) Name 

func (rcv *Field) Name() []byte

/ Name is not required, in i.e. a List

func (*Field) Nullable 

func (rcv *Field) Nullable() bool

/ 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

func (*Field) Type 

func (rcv *Field) Type(obj *flatbuffers.Table) bool

/ This is the type of the decoded value if the field is dictionary encoded.

func (*Field) TypeType 

func (rcv *Field) TypeType() Type

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) Init 

func (rcv *FieldNode) Init(buf []byte, i flatbuffers.UOffsetT)

func (*FieldNode) Length 

func (rcv *FieldNode) Length() int64

/ The number of value slots in the Arrow array at this level of a nested / tree

func (*FieldNode) MutateLength 

func (rcv *FieldNode) MutateLength(n int64) bool

/ The number of value slots in the Arrow array at this level of a nested / tree

func (*FieldNode) MutateNullCount 

func (rcv *FieldNode) MutateNullCount(n int64) bool

/ 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 

func (rcv *FieldNode) NullCount() int64

/ 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 struct {
	// contains filtered or unexported fields
}

/ ---------------------------------------------------------------------- / Arrow File metadata /

func GetRootAsFooter 

func GetRootAsFooter(buf []byte, offset flatbuffers.UOffsetT) *Footer

func (*Footer) CustomMetadata 

func (rcv *Footer) CustomMetadata(obj *KeyValue, j int) bool

/ User-defined metadata

func (*Footer) CustomMetadataLength 

func (rcv *Footer) CustomMetadataLength() int

func (*Footer) Dictionaries 

func (rcv *Footer) Dictionaries(obj *Block, j int) bool

func (*Footer) DictionariesLength 

func (rcv *Footer) DictionariesLength() int

func (*Footer) Init 

func (rcv *Footer) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Footer) MutateVersion 

func (rcv *Footer) MutateVersion(n MetadataVersion) bool

func (*Footer) RecordBatches 

func (rcv *Footer) RecordBatches(obj *Block, j int) bool

func (*Footer) RecordBatchesLength 

func (rcv *Footer) RecordBatchesLength() int

func (*Footer) Schema 

func (rcv *Footer) Schema(obj *Schema) *Schema

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) BitWidth 

func (rcv *Int) BitWidth() int32

func (*Int) Init 

func (rcv *Int) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Int) IsSigned 

func (rcv *Int) IsSigned() bool

func (*Int) MutateBitWidth 

func (rcv *Int) MutateBitWidth(n int32) bool

func (*Int) MutateIsSigned 

func (rcv *Int) MutateIsSigned(n bool) bool

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) Init 

func (rcv *Interval) Init(buf []byte, i flatbuffers.UOffsetT)

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) Init 

func (rcv *KeyValue) Init(buf []byte, i flatbuffers.UOffsetT)

func (*KeyValue) Key 

func (rcv *KeyValue) Key() []byte

func (*KeyValue) Table 

func (rcv *KeyValue) Table() flatbuffers.Table

func (*KeyValue) Value 

func (rcv *KeyValue) Value() []byte

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) Init 

func (rcv *LargeList) Init(buf []byte, i flatbuffers.UOffsetT)

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) Init 

func (rcv *LargeUtf8) Init(buf []byte, i flatbuffers.UOffsetT)

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) Init 

func (rcv *List) Init(buf []byte, i flatbuffers.UOffsetT)

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) Init 

func (rcv *Map) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Map) KeysSorted 

func (rcv *Map) KeysSorted() bool

/ Set to true if the keys within each value are sorted

func (*Map) MutateKeysSorted 

func (rcv *Map) MutateKeysSorted(n bool) bool

/ 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 (rcv *Message) BodyLength() int64

func (*Message) CustomMetadata 

func (rcv *Message) CustomMetadata(obj *KeyValue, j int) bool

func (*Message) CustomMetadataLength 

func (rcv *Message) CustomMetadataLength() int

func (*Message) Header 

func (rcv *Message) Header(obj *flatbuffers.Table) bool

func (*Message) HeaderType 

func (rcv *Message) HeaderType() MessageHeader

func (*Message) Init 

func (rcv *Message) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Message) MutateBodyLength 

func (rcv *Message) MutateBodyLength(n int64) bool

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) Init 

func (rcv *Null) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Null) Table 

func (rcv *Null) Table() flatbuffers.Table

type Precision 

type Precision int16
const (
	PrecisionHALF   Precision = 0
	PrecisionSINGLE Precision = 1
	PrecisionDOUBLE Precision = 2
)

func (Precision) String 

func (v Precision) String() string

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 RunEndEncoded 

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

/ Contains two child arrays, run_ends and values. / The run_ends child array must be a 16/32/64-bit integer array / which encodes the indices at which the run with the value in / each corresponding index in the values child array ends. / Like list/struct types, the value array can be of any type.

func GetRootAsRunEndEncoded 

func GetRootAsRunEndEncoded(buf []byte, offset flatbuffers.UOffsetT) *RunEndEncoded

func (*RunEndEncoded) Init 

func (rcv *RunEndEncoded) Init(buf []byte, i flatbuffers.UOffsetT)

func (*RunEndEncoded) Table 

func (rcv *RunEndEncoded) 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) CustomMetadata 

func (rcv *Schema) CustomMetadata(obj *KeyValue, j int) bool

func (*Schema) CustomMetadataLength 

func (rcv *Schema) CustomMetadataLength() int

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) Features 

func (rcv *Schema) Features(j int) Feature

/ Features used in the stream/file.

func (*Schema) FeaturesLength 

func (rcv *Schema) FeaturesLength() int

func (*Schema) Fields 

func (rcv *Schema) Fields(obj *Field, j int) bool

func (*Schema) FieldsLength 

func (rcv *Schema) FieldsLength() int

func (*Schema) Init 

func (rcv *Schema) Init(buf []byte, i flatbuffers.UOffsetT)

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 

func (rcv *Schema) MutateFeatures(j int, n Feature) bool

/ 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_) Init 

func (rcv *Struct_) Init(buf []byte, i flatbuffers.UOffsetT)

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) Data 

func (rcv *Tensor) Data(obj *Buffer) *Buffer

/ The location and size of the tensor's data

func (*Tensor) Init 

func (rcv *Tensor) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Tensor) MutateStrides 

func (rcv *Tensor) MutateStrides(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 (*Tensor) MutateTypeType 

func (rcv *Tensor) MutateTypeType(n Type) bool

func (*Tensor) Shape 

func (rcv *Tensor) 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 (*Tensor) ShapeLength 

func (rcv *Tensor) ShapeLength() int

func (*Tensor) Strides 

func (rcv *Tensor) Strides(j int) int64

/ 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 (rcv *Tensor) StridesLength() int

func (*Tensor) Table 

func (rcv *Tensor) Table() flatbuffers.Table

func (*Tensor) Type 

func (rcv *Tensor) 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 (*Tensor) TypeType 

func (rcv *Tensor) TypeType() Type

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) Init 

func (rcv *TensorDim) Init(buf []byte, i flatbuffers.UOffsetT)

func (*TensorDim) MutateSize 

func (rcv *TensorDim) MutateSize(n int64) bool

/ Length of dimension

func (*TensorDim) Name 

func (rcv *TensorDim) Name() []byte

/ Name of the dimension, optional

func (*TensorDim) Size 

func (rcv *TensorDim) Size() int64

/ Length of dimension

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) BitWidth 

func (rcv *Time) BitWidth() int32

func (*Time) Init 

func (rcv *Time) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Time) MutateBitWidth 

func (rcv *Time) MutateBitWidth(n int32) bool

func (*Time) MutateUnit 

func (rcv *Time) MutateUnit(n TimeUnit) bool

func (*Time) Table 

func (rcv *Time) Table() flatbuffers.Table

func (*Time) Unit 

func (rcv *Time) Unit() TimeUnit

type TimeUnit 

type TimeUnit int16
const (
	TimeUnitSECOND      TimeUnit = 0
	TimeUnitMILLISECOND TimeUnit = 1
	TimeUnitMICROSECOND TimeUnit = 2
	TimeUnitNANOSECOND  TimeUnit = 3
)

func (TimeUnit) String 

func (v TimeUnit) String() string

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) Init 

func (rcv *Timestamp) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Timestamp) MutateUnit 

func (rcv *Timestamp) MutateUnit(n TimeUnit) bool

func (*Timestamp) Table 

func (rcv *Timestamp) Table() flatbuffers.Table

func (*Timestamp) Timezone 

func (rcv *Timestamp) Timezone() []byte

/ 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 (*Timestamp) Unit 

func (rcv *Timestamp) Unit() TimeUnit

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
	TypeRunEndEncoded   Type = 22
)

func (Type) String 

func (v Type) String() string

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) Init 

func (rcv *Union) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Union) Mode 

func (rcv *Union) Mode() UnionMode

func (*Union) MutateMode 

func (rcv *Union) MutateMode(n UnionMode) bool

func (*Union) MutateTypeIds 

func (rcv *Union) MutateTypeIds(j int, n int32) bool

func (*Union) Table 

func (rcv *Union) Table() flatbuffers.Table

func (*Union) TypeIds 

func (rcv *Union) TypeIds(j int) int32

func (*Union) TypeIdsLength 

func (rcv *Union) TypeIdsLength() int

type UnionMode 

type UnionMode int16
const (
	UnionModeSparse UnionMode = 0
	UnionModeDense  UnionMode = 1
)

func (UnionMode) String 

func (v UnionMode) String() string

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) Init 

func (rcv *Utf8) Init(buf []byte, i flatbuffers.UOffsetT)

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 RunEndEncoded.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

Version
v11.0.0 (latest)
Published
Jan 18, 2023
Platform
linux/amd64
Imports
2 packages
Last checked
1 second ago –

Tools for package owners.