Function decimalToBigInt

server/flightclient/flight_executor.go:828–852

(val decimal128.Num, dt *arrow.Decimal128Type)

	if r.done || r.err != nil {
		return false
	}

	// Advance within current batch
	if r.currentBatch != nil && r.batchRow+1 < int(r.currentBatch.NumRows()) {
		r.batchRow++
		return true
	}

	// Release previous batch
	if r.currentBatch != nil {
		r.currentBatch.Release()
		r.currentBatch = nil
	}

	// Read next batch, skipping empty batches
	for r.reader.Next() {
		r.currentBatch = r.reader.RecordBatch()
		r.currentBatch.Retain()
		r.batchRow = 0
		if r.currentBatch.NumRows() > 0 {
			return true
		}
		r.currentBatch.Release()
		r.currentBatch = nil
	}

	r.done = true
	r.err = r.reader.Err()