typeutil

Documentation

Index

• func BuildRecord(b *array.RecordBuilder, data *storage.InsertData, ...) error
• func ConvertToArrowSchema(fields []*schemapb.FieldSchema) (*arrow.Schema, error)
• func FillRetrieveResultIfEmpty(result RetrieveResults, outputFieldIDs []int64, ...) error
• func GetStorageURI(protocol, pathPrefix string, segmentID int64) (string, error)
• func HashKey2Partitions(fieldSchema *schemapb.FieldSchema, keys []*planpb.GenericValue, ...) ([]string, error)
• type RetrieveResults
  • func NewInternalResult(result *internalpb.RetrieveResults) RetrieveResults
  • func NewMilvusResult(result *milvuspb.QueryResults) RetrieveResults
  • func NewSegcoreResults(result *segcorepb.RetrieveResults) RetrieveResults

Functions

func BuildRecord

func BuildRecord(b *array.RecordBuilder, data *storage.InsertData, fields []*schemapb.FieldSchema) error

func ConvertToArrowSchema

func ConvertToArrowSchema(fields []*schemapb.FieldSchema) (*arrow.Schema, error)

func FillRetrieveResultIfEmpty

func FillRetrieveResultIfEmpty(result RetrieveResults, outputFieldIDs []int64, schema *schemapb.CollectionSchema) error

func GetStorageURI

func GetStorageURI(protocol, pathPrefix string, segmentID int64) (string, error)

func HashKey2Partitions

func HashKey2Partitions(fieldSchema *schemapb.FieldSchema, keys []*planpb.GenericValue, partitionNames []string) ([]string, error)

HashKey2Partitions hash partition keys to partitions

Types

type RetrieveResults

type RetrieveResults interface {
	PreHandle()
	ResultEmpty() bool
	AppendFieldData(fieldData *schemapb.FieldData)
}

func NewInternalResult

func NewInternalResult(result *internalpb.RetrieveResults) RetrieveResults

func NewMilvusResult

func NewMilvusResult(result *milvuspb.QueryResults) RetrieveResults

func NewSegcoreResults

func NewSegcoreResults(result *segcorepb.RetrieveResults) RetrieveResults