Method parseUsedColumns

database/binlog/rows_event.go:311–332

(
	width int,
	data []byte)

}

func (p *baseRowsEventParser) parseUsedColumns(
	width int,
	data []byte) (
	usedColumns []ColumnDescriptor,
	remaining []byte,
	err error) {

	usedColumnBits, remaining, err := readBitArray(data, width)
	if err != nil {
		return nil, nil, err
	}

	allColumns := p.context.ColumnDescriptors()

	usedColumns = make([]ColumnDescriptor, 0, 0)
	for idx := 0; idx < width; idx++ {
		if usedColumnBits[idx] {
			usedColumns = append(usedColumns, allColumns[idx])
		}
	}
	return usedColumns, remaining, nil
}

func (p *baseRowsEventParser) parseRow(
	usedColumns []ColumnDescriptor,