admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-08 01:58:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

[skip ci] Add comment for PayloadReader (#12869)

Browse Source 
Signed-off-by: shaoyue.chen <shaoyue.chen@zilliz.com>
This commit is contained in:
shaoyue 2021-12-07 14:51:21 +08:00 committed by GitHub
parent 29c68eb901
commit ccf957e1a8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/storage/payload.go
View File

@ -399,11 +399,13 @@ func (r *PayloadReader) GetDataFromPayload(idx ...int) (interface{}, int, error)
} }
} }
// ReleasePayloadReader release payload reader.
func (r *PayloadReader) ReleasePayloadReader() error { func (r *PayloadReader) ReleasePayloadReader() error {
status := C.ReleasePayloadReader(r.payloadReaderPtr) status := C.ReleasePayloadReader(r.payloadReaderPtr)
return HandleCStatus(&status, "ReleasePayloadReader failed") return HandleCStatus(&status, "ReleasePayloadReader failed")
} }
// GetBoolFromPayload returns bool slice from payload.
func (r *PayloadReader) GetBoolFromPayload() ([]bool, error) { func (r *PayloadReader) GetBoolFromPayload() ([]bool, error) {
if r.colType != schemapb.DataType_Bool { if r.colType != schemapb.DataType_Bool {
return nil, errors.New("incorrect data type") return nil, errors.New("incorrect data type")
@ -421,6 +423,7 @@ func (r *PayloadReader) GetBoolFromPayload() ([]bool, error) {
return slice, nil return slice, nil
} }
// GetInt8FromPayload returns int8 slice from payload
func (r *PayloadReader) GetInt8FromPayload() ([]int8, error) { func (r *PayloadReader) GetInt8FromPayload() ([]int8, error) {
if r.colType != schemapb.DataType_Int8 { if r.colType != schemapb.DataType_Int8 {
return nil, errors.New("incorrect data type") return nil, errors.New("incorrect data type")