Method ReadColumn

client/column_decoder.go:91–141

(reader *bytes.Reader, dataType TSDataType, positionCount int32)

}

func (decoder *Int32ArrayColumnDecoder) ReadColumn(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error) {
	// Serialized data layout:
	//    +---------------+-----------------+-------------+
	//    | may have null | null indicators |   values    |
	//    +---------------+-----------------+-------------+
	//    | byte          | list[byte]      | list[int32] |
	//    +---------------+-----------------+-------------+

	if positionCount == 0 {
		switch dataType {
		case INT32, DATE:
			return NewIntColumn(0, 0, nil, []int32{})
		case FLOAT:
			return NewFloatColumn(0, 0, nil, []float32{})
		default:
			return nil, fmt.Errorf("invalid data type: %v", dataType)
		}
	}

	nullIndicators, err := deserializeNullIndicators(reader, positionCount)
	if err != nil {
		return nil, err
	}
	switch dataType {
	case INT32, DATE:
		intValues := make([]int32, positionCount)
		for i := int32(0); i < positionCount; i++ {
			if nullIndicators != nil && nullIndicators[i] {
				continue
			}
			err := binary.Read(reader, binary.BigEndian, &intValues[i])
			if err != nil {
				return nil, err
			}
		}
		return NewIntColumn(0, positionCount, nullIndicators, intValues)
	case FLOAT:
		floatValues := make([]float32, positionCount)
		for i := int32(0); i < positionCount; i++ {
			if nullIndicators != nil && nullIndicators[i] {
				continue
			}
			err := binary.Read(reader, binary.BigEndian, &floatValues[i])
			if err != nil {
				return nil, err
			}
		}
		return NewFloatColumn(0, positionCount, nullIndicators, floatValues)
	}
	return nil, fmt.Errorf("invalid data type: %v", dataType)
}

type Int64ArrayColumnDecoder struct {
	baseColumnDecoder