cockroach: github.com/cockroachdb/cockroach/pkg/col/colserde/arrowserde Index | Files

package arrowserde

import "github.com/cockroachdb/cockroach/pkg/col/colserde/arrowserde"

Package arrowserde contains the flatbuffer generated code used for Apache Arrow serialization (and some small helpers associated with the generated code).

Generated by: flatc --go --gen-onefile --go-namespace arrowserde -o . *.fbs

Index

Package Files

doc.go file_generated.go message_generated.go schema_generated.go tensor_generated.go

Variables

var EnumNamesDateUnit = map[DateUnit]string{
    DateUnitDAY:         "DAY",
    DateUnitMILLISECOND: "MILLISECOND",
}
var EnumNamesEndianness = map[Endianness]string{
    EndiannessLittle: "Little",
    EndiannessBig:    "Big",
}
var EnumNamesIntervalUnit = map[IntervalUnit]string{
    IntervalUnitYEAR_MONTH: "YEAR_MONTH",
    IntervalUnitDAY_TIME:   "DAY_TIME",
}
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",
}
var EnumNamesPrecision = map[Precision]string{
    PrecisionHALF:   "HALF",
    PrecisionSINGLE: "SINGLE",
    PrecisionDOUBLE: "DOUBLE",
}
var EnumNamesSparseTensorIndex = map[SparseTensorIndex]string{
    SparseTensorIndexNONE:                 "NONE",
    SparseTensorIndexSparseTensorIndexCOO: "SparseTensorIndexCOO",
    SparseTensorIndexSparseMatrixIndexCSR: "SparseMatrixIndexCSR",
}
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",
}
var EnumNamesUnionMode = map[UnionMode]string{
    UnionModeSparse: "Sparse",
    UnionModeDense:  "Dense",
}

func BinaryEnd Uses

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

func BinaryStart Uses

func BinaryStart(builder *flatbuffers.Builder)

func BoolEnd Uses

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

func BoolStart Uses

func BoolStart(builder *flatbuffers.Builder)

func CreateBlock Uses

func CreateBlock(
    builder *flatbuffers.Builder, offset int64, metaDataLength int32, bodyLength int64,
) flatbuffers.UOffsetT

func CreateBuffer Uses

func CreateBuffer(builder *flatbuffers.Builder, offset int64, length int64) flatbuffers.UOffsetT

func CreateFieldNode Uses

func CreateFieldNode(
    builder *flatbuffers.Builder, length int64, nullCount int64,
) flatbuffers.UOffsetT

func DateAddUnit Uses

func DateAddUnit(builder *flatbuffers.Builder, unit int16)

func DateEnd Uses

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

func DateStart Uses

func DateStart(builder *flatbuffers.Builder)

func DecimalAddPrecision Uses

func DecimalAddPrecision(builder *flatbuffers.Builder, precision int32)

func DecimalAddScale Uses

func DecimalAddScale(builder *flatbuffers.Builder, scale int32)

func DecimalEnd Uses

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

func DecimalStart Uses

func DecimalStart(builder *flatbuffers.Builder)

func DictionaryBatchAddData Uses

func DictionaryBatchAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)

func DictionaryBatchAddId Uses

func DictionaryBatchAddId(builder *flatbuffers.Builder, id int64)

func DictionaryBatchAddIsDelta Uses

func DictionaryBatchAddIsDelta(builder *flatbuffers.Builder, isDelta byte)

func DictionaryBatchEnd Uses

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

func DictionaryBatchStart Uses

func DictionaryBatchStart(builder *flatbuffers.Builder)

func DictionaryEncodingAddId Uses

func DictionaryEncodingAddId(builder *flatbuffers.Builder, id int64)

func DictionaryEncodingAddIndexType Uses

func DictionaryEncodingAddIndexType(builder *flatbuffers.Builder, indexType flatbuffers.UOffsetT)

func DictionaryEncodingAddIsOrdered Uses

func DictionaryEncodingAddIsOrdered(builder *flatbuffers.Builder, isOrdered byte)

func DictionaryEncodingEnd Uses

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

func DictionaryEncodingStart Uses

func DictionaryEncodingStart(builder *flatbuffers.Builder)

func FieldAddChildren Uses

func FieldAddChildren(builder *flatbuffers.Builder, children flatbuffers.UOffsetT)

func FieldAddCustomMetadata Uses

func FieldAddCustomMetadata(builder *flatbuffers.Builder, customMetadata flatbuffers.UOffsetT)

func FieldAddDictionary Uses

func FieldAddDictionary(builder *flatbuffers.Builder, dictionary flatbuffers.UOffsetT)

func FieldAddName Uses

func FieldAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)

func FieldAddNullable Uses

func FieldAddNullable(builder *flatbuffers.Builder, nullable byte)

func FieldAddType Uses

func FieldAddType(builder *flatbuffers.Builder, type_ flatbuffers.UOffsetT)

func FieldAddTypeType Uses

func FieldAddTypeType(builder *flatbuffers.Builder, typeType byte)

func FieldEnd Uses

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

func FieldStart Uses

func FieldStart(builder *flatbuffers.Builder)

func FieldStartChildrenVector Uses

func FieldStartChildrenVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func FieldStartCustomMetadataVector Uses

func FieldStartCustomMetadataVector(
    builder *flatbuffers.Builder, numElems int,
) flatbuffers.UOffsetT

func FixedSizeBinaryAddByteWidth Uses

func FixedSizeBinaryAddByteWidth(builder *flatbuffers.Builder, byteWidth int32)

func FixedSizeBinaryEnd Uses

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

func FixedSizeBinaryStart Uses

func FixedSizeBinaryStart(builder *flatbuffers.Builder)

func FixedSizeListAddListSize Uses

func FixedSizeListAddListSize(builder *flatbuffers.Builder, listSize int32)

func FixedSizeListEnd Uses

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

func FixedSizeListStart Uses

func FixedSizeListStart(builder *flatbuffers.Builder)

func FloatingPointAddPrecision Uses

func FloatingPointAddPrecision(builder *flatbuffers.Builder, precision int16)

func FloatingPointEnd Uses

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

func FloatingPointStart Uses

func FloatingPointStart(builder *flatbuffers.Builder)

func FooterAddDictionaries Uses

func FooterAddDictionaries(builder *flatbuffers.Builder, dictionaries flatbuffers.UOffsetT)

func FooterAddRecordBatches Uses

func FooterAddRecordBatches(builder *flatbuffers.Builder, recordBatches flatbuffers.UOffsetT)

func FooterAddSchema Uses

func FooterAddSchema(builder *flatbuffers.Builder, schema flatbuffers.UOffsetT)

func FooterAddVersion Uses

func FooterAddVersion(builder *flatbuffers.Builder, version int16)

func FooterEnd Uses

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

func FooterStart Uses

func FooterStart(builder *flatbuffers.Builder)

func FooterStartDictionariesVector Uses

func FooterStartDictionariesVector(
    builder *flatbuffers.Builder, numElems int,
) flatbuffers.UOffsetT

func FooterStartRecordBatchesVector Uses

func FooterStartRecordBatchesVector(
    builder *flatbuffers.Builder, numElems int,
) flatbuffers.UOffsetT

func IntAddBitWidth Uses

func IntAddBitWidth(builder *flatbuffers.Builder, bitWidth int32)

func IntAddIsSigned Uses

func IntAddIsSigned(builder *flatbuffers.Builder, isSigned byte)

func IntEnd Uses

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

func IntStart Uses

func IntStart(builder *flatbuffers.Builder)

func IntervalAddUnit Uses

func IntervalAddUnit(builder *flatbuffers.Builder, unit int16)

func IntervalEnd Uses

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

func IntervalStart Uses

func IntervalStart(builder *flatbuffers.Builder)

func KeyValueAddKey Uses

func KeyValueAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)

func KeyValueAddValue Uses

func KeyValueAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)

func KeyValueEnd Uses

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

func KeyValueStart Uses

func KeyValueStart(builder *flatbuffers.Builder)

func ListEnd Uses

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

func ListStart Uses

func ListStart(builder *flatbuffers.Builder)

func MapAddKeysSorted Uses

func MapAddKeysSorted(builder *flatbuffers.Builder, keysSorted byte)

func MapEnd Uses

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

func MapStart Uses

func MapStart(builder *flatbuffers.Builder)

func MessageAddBodyLength Uses

func MessageAddBodyLength(builder *flatbuffers.Builder, bodyLength int64)

func MessageAddHeader Uses

func MessageAddHeader(builder *flatbuffers.Builder, header flatbuffers.UOffsetT)

func MessageAddHeaderType Uses

func MessageAddHeaderType(builder *flatbuffers.Builder, headerType byte)

func MessageAddVersion Uses

func MessageAddVersion(builder *flatbuffers.Builder, version int16)

func MessageEnd Uses

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

func MessageStart Uses

func MessageStart(builder *flatbuffers.Builder)

func NullEnd Uses

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

func NullStart Uses

func NullStart(builder *flatbuffers.Builder)

func RecordBatchAddBuffers Uses

func RecordBatchAddBuffers(builder *flatbuffers.Builder, buffers flatbuffers.UOffsetT)

func RecordBatchAddLength Uses

func RecordBatchAddLength(builder *flatbuffers.Builder, length int64)

func RecordBatchAddNodes Uses

func RecordBatchAddNodes(builder *flatbuffers.Builder, nodes flatbuffers.UOffsetT)

func RecordBatchEnd Uses

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

func RecordBatchStart Uses

func RecordBatchStart(builder *flatbuffers.Builder)

/ 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 RecordBatchStartBuffersVector Uses

func RecordBatchStartBuffersVector(
    builder *flatbuffers.Builder, numElems int,
) flatbuffers.UOffsetT

func RecordBatchStartNodesVector Uses

func RecordBatchStartNodesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func SchemaAddCustomMetadata Uses

func SchemaAddCustomMetadata(builder *flatbuffers.Builder, customMetadata flatbuffers.UOffsetT)

func SchemaAddEndianness Uses

func SchemaAddEndianness(builder *flatbuffers.Builder, endianness int16)

func SchemaAddFields Uses

func SchemaAddFields(builder *flatbuffers.Builder, fields flatbuffers.UOffsetT)

func SchemaEnd Uses

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

func SchemaStart Uses

func SchemaStart(builder *flatbuffers.Builder)

func SchemaStartCustomMetadataVector Uses

func SchemaStartCustomMetadataVector(
    builder *flatbuffers.Builder, numElems int,
) flatbuffers.UOffsetT

func SchemaStartFieldsVector Uses

func SchemaStartFieldsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func SparseMatrixIndexCSRAddIndicesBuffer Uses

func SparseMatrixIndexCSRAddIndicesBuffer(
    builder *flatbuffers.Builder, indicesBuffer flatbuffers.UOffsetT,
)

func SparseMatrixIndexCSRAddIndptrBuffer Uses

func SparseMatrixIndexCSRAddIndptrBuffer(
    builder *flatbuffers.Builder, indptrBuffer flatbuffers.UOffsetT,
)

func SparseMatrixIndexCSREnd Uses

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

func SparseMatrixIndexCSRStart Uses

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

func SparseTensorAddData Uses

func SparseTensorAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)

func SparseTensorAddNonZeroLength Uses

func SparseTensorAddNonZeroLength(builder *flatbuffers.Builder, nonZeroLength int64)

func SparseTensorAddShape Uses

func SparseTensorAddShape(builder *flatbuffers.Builder, shape flatbuffers.UOffsetT)

func SparseTensorAddSparseIndex Uses

func SparseTensorAddSparseIndex(builder *flatbuffers.Builder, sparseIndex flatbuffers.UOffsetT)

func SparseTensorAddSparseIndexType Uses

func SparseTensorAddSparseIndexType(builder *flatbuffers.Builder, sparseIndexType byte)

func SparseTensorAddType Uses

func SparseTensorAddType(builder *flatbuffers.Builder, type_ flatbuffers.UOffsetT)

func SparseTensorAddTypeType Uses

func SparseTensorAddTypeType(builder *flatbuffers.Builder, typeType byte)

func SparseTensorEnd Uses

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

func SparseTensorIndexCOOAddIndicesBuffer Uses

func SparseTensorIndexCOOAddIndicesBuffer(
    builder *flatbuffers.Builder, indicesBuffer flatbuffers.UOffsetT,
)

func SparseTensorIndexCOOEnd Uses

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

func SparseTensorIndexCOOStart Uses

func SparseTensorIndexCOOStart(builder *flatbuffers.Builder)

/ 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 this index matrix. / The type of index value is long, so the stride for the index matrix is unnecessary. / / For example, let X be a 2x3x4x5 tensor, and it has the following 6 non-zero values: / / 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: / / [[0, 0, 0, 0, 1, 1], / [1, 1, 1, 2, 1, 2], / [2, 2, 3, 1, 2, 0], / [0, 1, 0, 0, 3, 4]] / / Note that the indices are sorted in lexcographical order.

func SparseTensorStart Uses

func SparseTensorStart(builder *flatbuffers.Builder)

/ The location and size of the tensor's data

func SparseTensorStartShapeVector Uses

func SparseTensorStartShapeVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func Struct_End Uses

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

func Struct_Start Uses

func Struct_Start(builder *flatbuffers.Builder)

func TensorAddData Uses

func TensorAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)

func TensorAddShape Uses

func TensorAddShape(builder *flatbuffers.Builder, shape flatbuffers.UOffsetT)

func TensorAddStrides Uses

func TensorAddStrides(builder *flatbuffers.Builder, strides flatbuffers.UOffsetT)

func TensorAddType Uses

func TensorAddType(builder *flatbuffers.Builder, type_ flatbuffers.UOffsetT)

func TensorAddTypeType Uses

func TensorAddTypeType(builder *flatbuffers.Builder, typeType byte)

func TensorDimAddName Uses

func TensorDimAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)

func TensorDimAddSize Uses

func TensorDimAddSize(builder *flatbuffers.Builder, size int64)

func TensorDimEnd Uses

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

func TensorDimStart Uses

func TensorDimStart(builder *flatbuffers.Builder)

/ Name of the dimension, optional

func TensorEnd Uses

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

func TensorStart Uses

func TensorStart(builder *flatbuffers.Builder)

/ The location and size of the tensor's data

func TensorStartShapeVector Uses

func TensorStartShapeVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func TensorStartStridesVector Uses

func TensorStartStridesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func TimeAddBitWidth Uses

func TimeAddBitWidth(builder *flatbuffers.Builder, bitWidth int32)

func TimeAddUnit Uses

func TimeAddUnit(builder *flatbuffers.Builder, unit int16)

func TimeEnd Uses

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

func TimeStart Uses

func TimeStart(builder *flatbuffers.Builder)

func TimestampAddTimezone Uses

func TimestampAddTimezone(builder *flatbuffers.Builder, timezone flatbuffers.UOffsetT)

func TimestampAddUnit Uses

func TimestampAddUnit(builder *flatbuffers.Builder, unit int16)

func TimestampEnd Uses

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

func TimestampStart Uses

func TimestampStart(builder *flatbuffers.Builder)

/ The time zone is a string indicating the name of a time zone, one of: / / * As used in the Olson time zone database (the "tz database" or / "tzdata"), such as "America/New_York" / * An absolute time zone 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: / / * If the time zone is null or equal to an empty string, the data is "time / zone naive" and shall be displayed *as is* to the user, not localized / to the locale of the user. This data can be though of as UTC but / without having "UTC" as the time zone, it is not considered to be / localized to any time zone / / * If the time zone is set to a valid value, values can be displayed as / "localized" to that time zone, even though the underlying 64-bit / integers are identical to the same data stored in UTC. Converting / between time zones is a metadata-only operation and does not change the / underlying values

func UnionAddMode Uses

func UnionAddMode(builder *flatbuffers.Builder, mode int16)

func UnionAddTypeIds Uses

func UnionAddTypeIds(builder *flatbuffers.Builder, typeIds flatbuffers.UOffsetT)

func UnionEnd Uses

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

func UnionStart Uses

func UnionStart(builder *flatbuffers.Builder)

func UnionStartTypeIdsVector Uses

func UnionStartTypeIdsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func Utf8End Uses

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

func Utf8Start Uses

func Utf8Start(builder *flatbuffers.Builder)

type Binary Uses

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

func GetRootAsBinary Uses

func GetRootAsBinary(buf []byte, offset flatbuffers.UOffsetT) *Binary

func (*Binary) Init Uses

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

func (*Binary) Table Uses

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

type Block Uses

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

func (*Block) BodyLength Uses

func (rcv *Block) BodyLength() int64

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

func (*Block) Init Uses

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

func (*Block) MetaDataLength Uses

func (rcv *Block) MetaDataLength() int32

/ Length of the metadata

func (*Block) MutateBodyLength Uses

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

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

func (*Block) MutateMetaDataLength Uses

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

/ Length of the metadata

func (*Block) MutateOffset Uses

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

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

func (*Block) Offset Uses

func (rcv *Block) Offset() int64

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

func (*Block) Table Uses

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

type Bool Uses

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

func GetRootAsBool Uses

func GetRootAsBool(buf []byte, offset flatbuffers.UOffsetT) *Bool

func (*Bool) Init Uses

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

func (*Bool) Table Uses

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

type Buffer Uses

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

/ ---------------------------------------------------------------------- / A Buffer represents a single contiguous memory segment

func (*Buffer) Init Uses

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

func (*Buffer) Length Uses

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

func (*Buffer) MutateLength Uses

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

func (*Buffer) MutateOffset Uses

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 Uses

func (rcv *Buffer) Offset() int64

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

func (*Buffer) Table Uses

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

type Date Uses

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

/ Date is either a 32-bit or 64-bit type representing 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 Uses

func GetRootAsDate(buf []byte, offset flatbuffers.UOffsetT) *Date

func (*Date) Init Uses

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

func (*Date) MutateUnit Uses

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

func (*Date) Table Uses

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

func (*Date) Unit Uses

func (rcv *Date) Unit() int16

type DateUnit Uses

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

type Decimal Uses

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

func GetRootAsDecimal Uses

func GetRootAsDecimal(buf []byte, offset flatbuffers.UOffsetT) *Decimal

func (*Decimal) Init Uses

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

func (*Decimal) MutatePrecision Uses

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

/ Total number of decimal digits

func (*Decimal) MutateScale Uses

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

/ Number of digits after the decimal point "."

func (*Decimal) Precision Uses

func (rcv *Decimal) Precision() int32

/ Total number of decimal digits

func (*Decimal) Scale Uses

func (rcv *Decimal) Scale() int32

/ Number of digits after the decimal point "."

func (*Decimal) Table Uses

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

type DictionaryBatch Uses

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 Uses

func GetRootAsDictionaryBatch(buf []byte, offset flatbuffers.UOffsetT) *DictionaryBatch

func (*DictionaryBatch) Data Uses

func (rcv *DictionaryBatch) Data(obj *RecordBatch) *RecordBatch

func (*DictionaryBatch) Id Uses

func (rcv *DictionaryBatch) Id() int64

func (*DictionaryBatch) Init Uses

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

func (*DictionaryBatch) IsDelta Uses

func (rcv *DictionaryBatch) IsDelta() byte

/ If isDelta is true the values in the dictionary are to be appended to a / dictionary with the indicated id

func (*DictionaryBatch) MutateId Uses

func (rcv *DictionaryBatch) MutateId(n int64) bool

func (*DictionaryBatch) MutateIsDelta Uses

func (rcv *DictionaryBatch) MutateIsDelta(n byte) bool

/ If isDelta is true the values in the dictionary are to be appended to a / dictionary with the indicated id

func (*DictionaryBatch) Table Uses

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

type DictionaryEncoding Uses

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

/ ---------------------------------------------------------------------- / Dictionary encoding metadata

func GetRootAsDictionaryEncoding Uses

func GetRootAsDictionaryEncoding(buf []byte, offset flatbuffers.UOffsetT) *DictionaryEncoding

func (*DictionaryEncoding) Id Uses

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 Uses

func (rcv *DictionaryEncoding) IndexType(obj *Int) *Int

/ The dictionary indices are constrained to be positive integers. If this / field is null, the indices must be signed int32

func (*DictionaryEncoding) Init Uses

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

func (*DictionaryEncoding) IsOrdered Uses

func (rcv *DictionaryEncoding) IsOrdered() byte

/ The dictionary indices are constrained to be positive integers. If this / field is null, the indices must be signed int32 / 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) MutateId Uses

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 Uses

func (rcv *DictionaryEncoding) MutateIsOrdered(n byte) 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 Uses

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

type Endianness Uses

type Endianness = int16

/ ---------------------------------------------------------------------- / Endianness of the platform producing the data

const (
    EndiannessLittle Endianness = 0
    EndiannessBig    Endianness = 1
)

type Field Uses

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. / / - children is only for nested Arrow arrays / - For primitive types, children will have length 0 / - nullable should default to true in general

func GetRootAsField Uses

func GetRootAsField(buf []byte, offset flatbuffers.UOffsetT) *Field

func (*Field) Children Uses

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

func (*Field) ChildrenLength Uses

func (rcv *Field) ChildrenLength() int

func (*Field) CustomMetadata Uses

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

func (*Field) CustomMetadataLength Uses

func (rcv *Field) CustomMetadataLength() int

func (*Field) Dictionary Uses

func (rcv *Field) Dictionary(obj *DictionaryEncoding) *DictionaryEncoding

func (*Field) Init Uses

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

func (*Field) MutateNullable Uses

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

func (*Field) MutateTypeType Uses

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

func (*Field) Name Uses

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

func (*Field) Nullable Uses

func (rcv *Field) Nullable() byte

func (*Field) Table Uses

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

func (*Field) Type Uses

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

func (*Field) TypeType Uses

func (rcv *Field) TypeType() byte

type FieldNode Uses

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 Uses

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

func (*FieldNode) Length Uses

func (rcv *FieldNode) Length() int64

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

func (*FieldNode) MutateLength Uses

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 Uses

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 Uses

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 Uses

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

type FixedSizeBinary Uses

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

func GetRootAsFixedSizeBinary Uses

func GetRootAsFixedSizeBinary(buf []byte, offset flatbuffers.UOffsetT) *FixedSizeBinary

func (*FixedSizeBinary) ByteWidth Uses

func (rcv *FixedSizeBinary) ByteWidth() int32

/ Number of bytes per value

func (*FixedSizeBinary) Init Uses

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

func (*FixedSizeBinary) MutateByteWidth Uses

func (rcv *FixedSizeBinary) MutateByteWidth(n int32) bool

/ Number of bytes per value

func (*FixedSizeBinary) Table Uses

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

type FixedSizeList Uses

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

func GetRootAsFixedSizeList Uses

func GetRootAsFixedSizeList(buf []byte, offset flatbuffers.UOffsetT) *FixedSizeList

func (*FixedSizeList) Init Uses

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

func (*FixedSizeList) ListSize Uses

func (rcv *FixedSizeList) ListSize() int32

/ Number of list items per value

func (*FixedSizeList) MutateListSize Uses

func (rcv *FixedSizeList) MutateListSize(n int32) bool

/ Number of list items per value

func (*FixedSizeList) Table Uses

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

type FloatingPoint Uses

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

func GetRootAsFloatingPoint Uses

func GetRootAsFloatingPoint(buf []byte, offset flatbuffers.UOffsetT) *FloatingPoint

func (*FloatingPoint) Init Uses

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

func (*FloatingPoint) MutatePrecision Uses

func (rcv *FloatingPoint) MutatePrecision(n int16) bool

func (*FloatingPoint) Precision Uses

func (rcv *FloatingPoint) Precision() int16

func (*FloatingPoint) Table Uses

func (rcv *FloatingPoint) Table() flatbuffers.Table
type Footer struct {
    // contains filtered or unexported fields
}

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

func GetRootAsFooter Uses

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

func (*Footer) Dictionaries Uses

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

func (*Footer) DictionariesLength Uses

func (rcv *Footer) DictionariesLength() int

func (*Footer) Init Uses

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

func (*Footer) MutateVersion Uses

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

func (*Footer) RecordBatches Uses

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

func (*Footer) RecordBatchesLength Uses

func (rcv *Footer) RecordBatchesLength() int

func (*Footer) Schema Uses

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

func (*Footer) Table Uses

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

func (*Footer) Version Uses

func (rcv *Footer) Version() int16

type Int Uses

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

func GetRootAsInt Uses

func GetRootAsInt(buf []byte, offset flatbuffers.UOffsetT) *Int

func (*Int) BitWidth Uses

func (rcv *Int) BitWidth() int32

func (*Int) Init Uses

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

func (*Int) IsSigned Uses

func (rcv *Int) IsSigned() byte

func (*Int) MutateBitWidth Uses

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

func (*Int) MutateIsSigned Uses

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

func (*Int) Table Uses

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

type Interval Uses

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

func GetRootAsInterval Uses

func GetRootAsInterval(buf []byte, offset flatbuffers.UOffsetT) *Interval

func (*Interval) Init Uses

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

func (*Interval) MutateUnit Uses

func (rcv *Interval) MutateUnit(n int16) bool

func (*Interval) Table Uses

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

func (*Interval) Unit Uses

func (rcv *Interval) Unit() int16

type IntervalUnit Uses

type IntervalUnit = int16
const (
    IntervalUnitYEAR_MONTH IntervalUnit = 0
    IntervalUnitDAY_TIME   IntervalUnit = 1
)

type KeyValue Uses

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 Uses

func GetRootAsKeyValue(buf []byte, offset flatbuffers.UOffsetT) *KeyValue

func (*KeyValue) Init Uses

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

func (*KeyValue) Key Uses

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

func (*KeyValue) Table Uses

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

func (*KeyValue) Value Uses

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

type List Uses

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

func GetRootAsList Uses

func GetRootAsList(buf []byte, offset flatbuffers.UOffsetT) *List

func (*List) Init Uses

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

func (*List) Table Uses

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

type Map Uses

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

/ A Map is a logical nested type that is represented as / / List<entry: 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 "entry", "key", and "value", but this is / not enforced / / Map / - child[0] entry: Struct / - child[0] key: K / - child[1] value: V / / Neither the "entry" 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 Uses

func GetRootAsMap(buf []byte, offset flatbuffers.UOffsetT) *Map

func (*Map) Init Uses

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

func (*Map) KeysSorted Uses

func (rcv *Map) KeysSorted() byte

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

func (*Map) MutateKeysSorted Uses

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

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

func (*Map) Table Uses

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

type Message Uses

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

func GetRootAsMessage Uses

func GetRootAsMessage(buf []byte, offset flatbuffers.UOffsetT) *Message

func (*Message) BodyLength Uses

func (rcv *Message) BodyLength() int64

func (*Message) Header Uses

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

func (*Message) HeaderType Uses

func (rcv *Message) HeaderType() byte

func (*Message) Init Uses

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

func (*Message) MutateBodyLength Uses

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

func (*Message) MutateHeaderType Uses

func (rcv *Message) MutateHeaderType(n byte) bool

func (*Message) MutateVersion Uses

func (rcv *Message) MutateVersion(n int16) bool

func (*Message) Table Uses

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

func (*Message) Version Uses

func (rcv *Message) Version() int16

type MessageHeader Uses

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
)

type MetadataVersion Uses

type MetadataVersion = int16
const (
    /// 0.1.0
    MetadataVersionV1 MetadataVersion = 0
    /// 0.2.0
    MetadataVersionV2 MetadataVersion = 1
    /// 0.3.0 -> 0.7.1
    MetadataVersionV3 MetadataVersion = 2
    /// >= 0.8.0
    MetadataVersionV4 MetadataVersion = 3
)

type Null Uses

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

/ These are stored in the flatbuffer in the Type union below

func GetRootAsNull Uses

func GetRootAsNull(buf []byte, offset flatbuffers.UOffsetT) *Null

func (*Null) Init Uses

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

func (*Null) Table Uses

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

type Precision Uses

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

type RecordBatch Uses

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 Uses

func GetRootAsRecordBatch(buf []byte, offset flatbuffers.UOffsetT) *RecordBatch

func (*RecordBatch) Buffers Uses

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 Uses

func (rcv *RecordBatch) BuffersLength() int

func (*RecordBatch) Init Uses

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

func (*RecordBatch) Length Uses

func (rcv *RecordBatch) Length() int64

/ number of records / rows. The arrays in the batch should all have this / length

func (*RecordBatch) MutateLength Uses

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

/ number of records / rows. The arrays in the batch should all have this / length

func (*RecordBatch) Nodes Uses

func (rcv *RecordBatch) Nodes(obj *FieldNode, j int) bool

/ Nodes correspond to the pre-ordered flattened logical schema

func (*RecordBatch) NodesLength Uses

func (rcv *RecordBatch) NodesLength() int

func (*RecordBatch) Table Uses

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

type Schema Uses

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

/ ---------------------------------------------------------------------- / A Schema describes the columns in a row batch

func GetRootAsSchema Uses

func GetRootAsSchema(buf []byte, offset flatbuffers.UOffsetT) *Schema

func (*Schema) CustomMetadata Uses

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

func (*Schema) CustomMetadataLength Uses

func (rcv *Schema) CustomMetadataLength() int

func (*Schema) Endianness Uses

func (rcv *Schema) Endianness() int16

/ 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) Fields Uses

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

func (*Schema) FieldsLength Uses

func (rcv *Schema) FieldsLength() int

func (*Schema) Init Uses

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

func (*Schema) MutateEndianness Uses

func (rcv *Schema) MutateEndianness(n int16) 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) Table Uses

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

type SparseMatrixIndexCSR Uses

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

/ Compressed Sparse Row format, that is matrix-specific.

func GetRootAsSparseMatrixIndexCSR Uses

func GetRootAsSparseMatrixIndexCSR(buf []byte, offset flatbuffers.UOffsetT) *SparseMatrixIndexCSR

func (*SparseMatrixIndexCSR) IndicesBuffer Uses

func (rcv *SparseMatrixIndexCSR) IndicesBuffer(obj *Buffer) *Buffer

/ 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]. / 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].

func (*SparseMatrixIndexCSR) IndptrBuffer Uses

func (rcv *SparseMatrixIndexCSR) IndptrBuffer(obj *Buffer) *Buffer

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

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

func (*SparseMatrixIndexCSR) Table Uses

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

type SparseTensor Uses

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

func GetRootAsSparseTensor Uses

func GetRootAsSparseTensor(buf []byte, offset flatbuffers.UOffsetT) *SparseTensor

func (*SparseTensor) Data Uses

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

/ Sparse tensor index / The location and size of the tensor's data

func (*SparseTensor) Init Uses

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

func (*SparseTensor) MutateNonZeroLength Uses

func (rcv *SparseTensor) MutateNonZeroLength(n int64) bool

/ The number of non-zero values in a sparse tensor.

func (*SparseTensor) MutateSparseIndexType Uses

func (rcv *SparseTensor) MutateSparseIndexType(n byte) bool

func (*SparseTensor) MutateTypeType Uses

func (rcv *SparseTensor) MutateTypeType(n byte) bool

func (*SparseTensor) NonZeroLength Uses

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 Uses

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 Uses

func (rcv *SparseTensor) ShapeLength() int

func (*SparseTensor) SparseIndex Uses

func (rcv *SparseTensor) SparseIndex(obj *flatbuffers.Table) bool

/ Sparse tensor index

func (*SparseTensor) SparseIndexType Uses

func (rcv *SparseTensor) SparseIndexType() byte

func (*SparseTensor) Table Uses

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

func (*SparseTensor) Type Uses

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 Uses

func (rcv *SparseTensor) TypeType() byte

type SparseTensorIndex Uses

type SparseTensorIndex = byte
const (
    SparseTensorIndexNONE                 SparseTensorIndex = 0
    SparseTensorIndexSparseTensorIndexCOO SparseTensorIndex = 1
    SparseTensorIndexSparseMatrixIndexCSR SparseTensorIndex = 2
)

type SparseTensorIndexCOO Uses

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

/ ---------------------------------------------------------------------- / EXPERIMENTAL: Data structures for sparse tensors / Coodinate format of sparse tensor index.

func GetRootAsSparseTensorIndexCOO Uses

func GetRootAsSparseTensorIndexCOO(buf []byte, offset flatbuffers.UOffsetT) *SparseTensorIndexCOO

func (*SparseTensorIndexCOO) IndicesBuffer Uses

func (rcv *SparseTensorIndexCOO) IndicesBuffer(obj *Buffer) *Buffer

/ 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 this index matrix. / The type of index value is long, so the stride for the index matrix is unnecessary. / / For example, let X be a 2x3x4x5 tensor, and it has the following 6 non-zero values: / / 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: / / [[0, 0, 0, 0, 1, 1], / [1, 1, 1, 2, 1, 2], / [2, 2, 3, 1, 2, 0], / [0, 1, 0, 0, 3, 4]] / / Note that the indices are sorted in lexcographical order.

func (*SparseTensorIndexCOO) Init Uses

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

func (*SparseTensorIndexCOO) Table Uses

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

type Struct_ Uses

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_ Uses

func GetRootAsStruct_(buf []byte, offset flatbuffers.UOffsetT) *Struct_

func (*Struct_) Init Uses

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

func (*Struct_) Table Uses

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

type Tensor Uses

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

func GetRootAsTensor Uses

func GetRootAsTensor(buf []byte, offset flatbuffers.UOffsetT) *Tensor

func (*Tensor) Data Uses

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

/ Non-negative byte offsets to advance one value cell along each dimension / The location and size of the tensor's data

func (*Tensor) Init Uses

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

func (*Tensor) MutateTypeType Uses

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

func (*Tensor) Shape Uses

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 Uses

func (rcv *Tensor) ShapeLength() int

func (*Tensor) Strides Uses

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

func (*Tensor) StridesLength Uses

func (rcv *Tensor) StridesLength() int

func (*Tensor) Table Uses

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

func (*Tensor) Type Uses

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 Uses

func (rcv *Tensor) TypeType() byte

type TensorDim Uses

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

/ ---------------------------------------------------------------------- / Data structures for dense tensors / Shape data for a single axis in a tensor

func GetRootAsTensorDim Uses

func GetRootAsTensorDim(buf []byte, offset flatbuffers.UOffsetT) *TensorDim

func (*TensorDim) Init Uses

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

func (*TensorDim) MutateSize Uses

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

/ Length of dimension

func (*TensorDim) Name Uses

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

/ Name of the dimension, optional

func (*TensorDim) Size Uses

func (rcv *TensorDim) Size() int64

/ Length of dimension

func (*TensorDim) Table Uses

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

type Time Uses

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

/ Time type. The physical storage type depends on the unit / - SECOND and MILLISECOND: 32 bits / - MICROSECOND and NANOSECOND: 64 bits

func GetRootAsTime Uses

func GetRootAsTime(buf []byte, offset flatbuffers.UOffsetT) *Time

func (*Time) BitWidth Uses

func (rcv *Time) BitWidth() int32

func (*Time) Init Uses

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

func (*Time) MutateBitWidth Uses

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

func (*Time) MutateUnit Uses

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

func (*Time) Table Uses

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

func (*Time) Unit Uses

func (rcv *Time) Unit() int16

type TimeUnit Uses

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

type Timestamp Uses

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

/ Time elapsed from the Unix epoch, 00:00:00.000 on 1 January 1970, excluding / leap seconds, as a 64-bit integer. Note that UNIX time does not include / leap seconds. / / The Timestamp metadata supports both "time zone naive" and "time zone / aware" timestamps. Read about the timezone attribute for more detail

func GetRootAsTimestamp Uses

func GetRootAsTimestamp(buf []byte, offset flatbuffers.UOffsetT) *Timestamp

func (*Timestamp) Init Uses

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

func (*Timestamp) MutateUnit Uses

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

func (*Timestamp) Table Uses

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

func (*Timestamp) Timezone Uses

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

/ The time zone is a string indicating the name of a time zone, one of: / / * As used in the Olson time zone database (the "tz database" or / "tzdata"), such as "America/New_York" / * An absolute time zone 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: / / * If the time zone is null or equal to an empty string, the data is "time / zone naive" and shall be displayed *as is* to the user, not localized / to the locale of the user. This data can be though of as UTC but / without having "UTC" as the time zone, it is not considered to be / localized to any time zone / / * If the time zone is set to a valid value, values can be displayed as / "localized" to that time zone, even though the underlying 64-bit / integers are identical to the same data stored in UTC. Converting / between time zones is a metadata-only operation and does not change the / underlying values

func (*Timestamp) Unit Uses

func (rcv *Timestamp) Unit() int16

type Type Uses

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
)

type Union Uses

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 Uses

func GetRootAsUnion(buf []byte, offset flatbuffers.UOffsetT) *Union

func (*Union) Init Uses

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

func (*Union) Mode Uses

func (rcv *Union) Mode() int16

func (*Union) MutateMode Uses

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

func (*Union) Table Uses

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

func (*Union) TypeIds Uses

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

func (*Union) TypeIdsLength Uses

func (rcv *Union) TypeIdsLength() int

type UnionMode Uses

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

type Utf8 Uses

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

/ Unicode with UTF-8 encoding

func GetRootAsUtf8 Uses

func GetRootAsUtf8(buf []byte, offset flatbuffers.UOffsetT) *Utf8

func (*Utf8) Init Uses

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

func (*Utf8) Table Uses

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

Package arrowserde imports 1 packages (graph) and is imported by 1 packages. Updated 2019-08-16. Refresh now. Tools for package owners.