未验证 提交 d5aa125c 编写于 作者: S shaoyue 提交者: GitHub

[skip ci] Add comment for StatsReader (#12870)

Signed-off-by: Nshaoyue.chen <shaoyue.chen@zilliz.com>
上级 ccf957e1
......@@ -70,14 +70,17 @@ func (sw *StatsWriter) StatsInt64(fieldID int64, isPrimaryKey bool, msgs []int64
return nil
}
// StatsReade reads stats
type StatsReader struct {
buffer []byte
}
// SetBuffer sets buffer
func (sr *StatsReader) SetBuffer(buffer []byte) {
sr.buffer = buffer
}
// GetInt64Stats returns buffer as Int64Stats
func (sr *StatsReader) GetInt64Stats() (*Int64Stats, error) {
stats := &Int64Stats{}
err := json.Unmarshal(sr.buffer, &stats)
......@@ -87,6 +90,7 @@ func (sr *StatsReader) GetInt64Stats() (*Int64Stats, error) {
return stats, nil
}
// DeserializeStats deserialize @blobs as []*Int64Stats
func DeserializeStats(blobs []*Blob) ([]*Int64Stats, error) {
results := make([]*Int64Stats, 0, len(blobs))
for _, blob := range blobs {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册