Method getLongByTsBlockColumnIndex

client/rpcdataset.go:442–465

(tsBlockColumnIndex int32)

}

func (s *IoTDBRpcDataSet) getLongByTsBlockColumnIndex(tsBlockColumnIndex int32) (int64, error) {
	if err := s.checkRecord(); err != nil {
		return 0, err
	}
	if tsBlockColumnIndex < 0 {
		s.lastReadWasNull = false
		return s.curTsBlock.GetTimeByIndex(s.tsBlockIndex)
	}
	if !s.isNull(tsBlockColumnIndex, s.tsBlockIndex) {
		s.lastReadWasNull = false
		dataType := s.curTsBlock.GetColumn(tsBlockColumnIndex).GetDataType()
		if dataType == INT32 {
			if v, err := s.curTsBlock.GetColumn(tsBlockColumnIndex).GetInt(s.tsBlockIndex); err != nil {
				return 0, err
			} else {
				return int64(v), nil
			}
		}
		return s.curTsBlock.GetColumn(tsBlockColumnIndex).GetLong(s.tsBlockIndex)
	} else {
		s.lastReadWasNull = true
		return 0, nil
	}
}

func (s *IoTDBRpcDataSet) getBinaryByIndex(columnIndex int32) (*Binary, error) {
	if index, err := s.getTsBlockColumnIndexForColumnIndex(columnIndex); err != nil {