Method ReadColumn

client/column_decoder.go:147–195

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

}

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

	if positionCount == 0 {
		switch dataType {
		case INT64, TIMESTAMP:
			return NewLongColumn(0, 0, nil, []int64{})
		case DOUBLE:
			return NewDoubleColumn(0, 0, nil, []float64{})
		default:
			return nil, fmt.Errorf("invalid data type: %v", dataType)
		}
	}

	nullIndicators, err := deserializeNullIndicators(reader, positionCount)
	if err != nil {
		return nil, err
	}
	switch dataType {
	case INT64, TIMESTAMP:
		values := make([]int64, positionCount)
		for i := int32(0); i < positionCount; i++ {
			if nullIndicators != nil && nullIndicators[i] {
				continue
			}
			if err = binary.Read(reader, binary.BigEndian, &values[i]); err != nil {
				return nil, err
			}
		}
		return NewLongColumn(0, positionCount, nullIndicators, values)
	case DOUBLE:
		values := make([]float64, positionCount)
		for i := int32(0); i < positionCount; i++ {
			if nullIndicators != nil && nullIndicators[i] {
				continue
			}
			if err = binary.Read(reader, binary.BigEndian, &values[i]); err != nil {
				return nil, err
			}
		}
		return NewDoubleColumn(0, positionCount, nullIndicators, values)
	}
	return nil, fmt.Errorf("invalid data type: %v", dataType)
}

type ByteArrayColumnDecoder struct {
	baseColumnDecoder