Documentation
¶
Index ¶
- func ConvertToArrowSchema(schema *schemapb.CollectionSchema) (*arrow.Schema, error)
- func CreateFieldReaders(ctx context.Context, fileReader *pqarrow.FileReader, ...) (map[int64]*FieldReader, error)
- func NewReader(ctx context.Context, cm storage.ChunkManager, ...) (*reader, error)
- func ReadBinaryData(pcr *FieldReader, dataType schemapb.DataType, count int64) (any, error)
- func ReadBoolArrayData(pcr *FieldReader, count int64) (any, error)
- func ReadBoolData(pcr *FieldReader, count int64) (any, error)
- func ReadIntegerOrFloatArrayData[T constraints.Integer | constraints.Float](pcr *FieldReader, count int64) (any, error)
- func ReadIntegerOrFloatData[T constraints.Integer | constraints.Float](pcr *FieldReader, count int64) (any, error)
- func ReadStringArrayData(pcr *FieldReader, count int64) (any, error)
- func ReadStringData(pcr *FieldReader, count int64) (any, error)
- func WrapTypeErr(expect string, actual string, field *schemapb.FieldSchema) error
- type FieldReader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertToArrowSchema ¶
func ConvertToArrowSchema(schema *schemapb.CollectionSchema) (*arrow.Schema, error)
func CreateFieldReaders ¶
func CreateFieldReaders(ctx context.Context, fileReader *pqarrow.FileReader, schema *schemapb.CollectionSchema) (map[int64]*FieldReader, error)
func NewReader ¶
func NewReader(ctx context.Context, cm storage.ChunkManager, schema *schemapb.CollectionSchema, path string, bufferSize int) (*reader, error)
func ReadBinaryData ¶
func ReadBoolArrayData ¶
func ReadBoolArrayData(pcr *FieldReader, count int64) (any, error)
func ReadBoolData ¶
func ReadBoolData(pcr *FieldReader, count int64) (any, error)
func ReadIntegerOrFloatArrayData ¶
func ReadIntegerOrFloatArrayData[T constraints.Integer | constraints.Float](pcr *FieldReader, count int64) (any, error)
func ReadIntegerOrFloatData ¶
func ReadIntegerOrFloatData[T constraints.Integer | constraints.Float](pcr *FieldReader, count int64) (any, error)
func ReadStringArrayData ¶
func ReadStringArrayData(pcr *FieldReader, count int64) (any, error)
func ReadStringData ¶
func ReadStringData(pcr *FieldReader, count int64) (any, error)
func WrapTypeErr ¶
func WrapTypeErr(expect string, actual string, field *schemapb.FieldSchema) error
Types ¶
type FieldReader ¶
type FieldReader struct {
// contains filtered or unexported fields
}
func NewFieldReader ¶
func NewFieldReader(ctx context.Context, reader *pqarrow.FileReader, columnIndex int, field *schemapb.FieldSchema) (*FieldReader, error)
func (*FieldReader) Close ¶
func (c *FieldReader) Close()
Source Files
Click to show internal directories.
Click to hide internal directories.