in src/afs.cc [1441:1460]
arrow::Status assign_parameters(
const std::shared_ptr<arrow::RecordBatch>& recordBatch,
int64_t i_row,
const std::vector<std::shared_ptr<arrow::Array>>& columns,
SPIExecuteOptions& options)
{
int64_t i_column = 0;
for (const auto& column : columns)
{
auto param = &(options.params->params[i_column]);
param->isnull = column->IsNull(i_row);
if (!param->isnull)
{
ArrowPGValueConverter converter(i_row, param->value);
ARROW_RETURN_NOT_OK(column->Accept(&converter));
}
++i_column;
}
return arrow::Status::OK();
}