numpy

Documentation

Index

• func CreateReaders(ctx context.Context, cm storage.ChunkManager, ...) (map[int64]io.Reader, error)
• func NewReader(ctx context.Context, cm storage.ChunkManager, ...) (*reader, error)
• func ReadN[T any](reader io.Reader, order binary.ByteOrder, n int64) ([]T, error)
• type FieldReader
  • func NewFieldReader(reader io.Reader, field *schemapb.FieldSchema) (*FieldReader, error)
  • func (c *FieldReader) Close()
  • func (c *FieldReader) Next(count int64) (any, error)
  • func (c *FieldReader) ReadString(count int64) ([]string, error)

Functions

func CreateReaders

func CreateReaders(ctx context.Context, cm storage.ChunkManager, schema *schemapb.CollectionSchema, paths []string) (map[int64]io.Reader, error)

func NewReader

func NewReader(ctx context.Context, cm storage.ChunkManager, schema *schemapb.CollectionSchema, paths []string, bufferSize int) (*reader, error)

func ReadN

func ReadN[T any](reader io.Reader, order binary.ByteOrder, n int64) ([]T, error)

Types

type FieldReader

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

func NewFieldReader

func NewFieldReader(reader io.Reader, field *schemapb.FieldSchema) (*FieldReader, error)

func (*FieldReader) Close

func (c *FieldReader) Close()

func (*FieldReader) Next

func (c *FieldReader) Next(count int64) (any, error)

func (*FieldReader) ReadString

func (c *FieldReader) ReadString(count int64) ([]string, error)