(tsBlockColumnIndex int32)
| 374 | } |
| 375 | |
| 376 | func (s *IoTDBRpcDataSet) getFloatByTsBlockColumnIndex(tsBlockColumnIndex int32) (float32, error) { |
| 377 | if err := s.checkRecord(); err != nil { |
| 378 | return 0, err |
| 379 | } |
| 380 | if !s.isNull(tsBlockColumnIndex, s.tsBlockIndex) { |
| 381 | s.lastReadWasNull = false |
| 382 | return s.curTsBlock.GetColumn(tsBlockColumnIndex).GetFloat(s.tsBlockIndex) |
| 383 | } else { |
| 384 | s.lastReadWasNull = true |
| 385 | return 0, nil |
| 386 | } |
| 387 | } |
| 388 | |
| 389 | func (s *IoTDBRpcDataSet) getIntByIndex(columnIndex int32) (int32, error) { |
| 390 | if index, err := s.getTsBlockColumnIndexForColumnIndex(columnIndex); err != nil { |
no test coverage detected