in src/afs.cc [1341:1357]
arrow::Status set_parameters(std::shared_ptr<SharedRingBufferInputStream>& input)
{
parameters_.clear();
ARROW_ASSIGN_OR_RAISE(auto reader,
arrow::ipc::RecordBatchStreamReader::Open(input));
while (true)
{
std::shared_ptr<arrow::RecordBatch> recordBatch;
ARROW_RETURN_NOT_OK(reader->ReadNext(&recordBatch));
if (!recordBatch)
{
break;
}
parameters_.push_back(std::move(recordBatch));
}
return arrow::Status::OK();
}