Function deserializeBooleanArray

client/column_decoder.go:44–83

(reader *bytes.Reader, size int32)

}

func deserializeBooleanArray(reader *bytes.Reader, size int32) ([]bool, error) {
	packedSize := (size + 7) / 8
	packedBytes := make([]byte, packedSize)

	_, err := reader.Read(packedBytes)
	if err != nil {
		return nil, err
	}

	// read null bits 8 at a time
	output := make([]bool, size)
	currentByte := 0
	fullGroups := int(size) & ^0b111
	for pos := 0; pos < fullGroups; pos += 8 {
		b := packedBytes[currentByte]
		currentByte++

		output[pos+0] = (b & 0b10000000) != 0
		output[pos+1] = (b & 0b01000000) != 0
		output[pos+2] = (b & 0b00100000) != 0
		output[pos+3] = (b & 0b00010000) != 0
		output[pos+4] = (b & 0b00001000) != 0
		output[pos+5] = (b & 0b00000100) != 0
		output[pos+6] = (b & 0b00000010) != 0
		output[pos+7] = (b & 0b00000001) != 0
	}

	// read last null bits
	if remaining := int(size) % 8; remaining > 0 {
		b := packedBytes[len(packedBytes)-1]
		mask := uint8(0b10000000)

		for pos := fullGroups; pos < int(size); pos++ {
			output[pos] = (b & mask) != 0
			mask >>= 1
		}
	}

	return output, nil
}

type baseColumnDecoder struct{}