()
| 266 | } |
| 267 | |
| 268 | func (s *IoTDBRpcDataSet) constructOneTsBlock() (err error) { |
| 269 | s.lastReadWasNull = false |
| 270 | curTsBlockBytes := s.queryResult[s.queryResultIndex] |
| 271 | s.queryResultIndex = s.queryResultIndex + 1 |
| 272 | s.curTsBlock, err = DeserializeTsBlock(curTsBlockBytes) |
| 273 | if err != nil { |
| 274 | return err |
| 275 | } |
| 276 | s.tsBlockIndex = -1 |
| 277 | s.tsBlockSize = s.curTsBlock.GetPositionCount() |
| 278 | return nil |
| 279 | } |
| 280 | |
| 281 | func (s *IoTDBRpcDataSet) isNullByIndex(columnIndex int32) (bool, error) { |
| 282 | if index, err := s.getTsBlockColumnIndexForColumnIndex(columnIndex); err != nil { |
no test coverage detected