Skip to content
Snippets Groups Projects
Unverified Commit 265b4f09 authored by GreatRiver's avatar GreatRiver Committed by GitHub
Browse files

Add rows for WriteIBatch (#2825)

parent 9e0f5792
No related branches found
No related tags found
No related merge requests found
......@@ -311,6 +311,9 @@ func (bf *blockFile) WriteIBatch(bat batch.IBatch, ts uint64, masks map[uint16]*
if err = bf.WriteTS(ts); err != nil {
return err
}
if err = bf.WriteRows(uint32(bat.Length())); err != nil {
return err
}
for _, colIdx := range attrs {
cb, err := bf.OpenColumn(colIdx)
if err != nil {
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment