Method ReadColumn

client/column_decoder.go:232–282

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

}

func (decoder *BinaryArrayColumnDecoder) ReadColumn(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error) {
	// Serialized data layout:
	//    +---------------+-----------------+-------------+
	//    | may have null | null indicators |   values    |
	//    +---------------+-----------------+-------------+
	//    | byte          | list[byte]      | list[entry] |
	//    +---------------+-----------------+-------------+
	//
	// Each entry is represented as:
	//    +---------------+-------+
	//    | value length  | value |
	//    +---------------+-------+
	//    | int32         | bytes |
	//    +---------------+-------+

	if TEXT != dataType {
		return nil, fmt.Errorf("invalid data type: %v", dataType)
	}

	if positionCount == 0 {
		return NewBinaryColumn(0, 0, nil, []*Binary{})
	}

	nullIndicators, err := deserializeNullIndicators(reader, positionCount)
	if err != nil {
		return nil, err
	}
	values := make([]*Binary, positionCount)
	for i := int32(0); i < positionCount; i++ {
		if nullIndicators != nil && nullIndicators[i] {
			continue
		}
		var length int32
		err := binary.Read(reader, binary.BigEndian, &length)
		if err != nil {
			return nil, err
		}

		if length == 0 {
			values[i] = NewBinary([]byte{})
		} else {
			value := make([]byte, length)
			_, err = reader.Read(value)
			if err != nil {
				return nil, err
			}
			values[i] = NewBinary(value)
		}
	}
	return NewBinaryColumn(0, positionCount, nullIndicators, values)
}

type RunLengthColumnDecoder struct {
	baseColumnDecoder