Method CreateRecordBatch

cpp/src/arrow/ipc/reader.cc:620–638

// buffer decompression, dictionary resolution, buffer re-alignment.
struct RecordBatchLoader {
  Result<std::shared_ptr<RecordBatch>> CreateRecordBatch(ArrayDataVector columns) {
    ARROW_ASSIGN_OR_RAISE(auto filtered_columns, CreateColumns(std::move(columns)));

    std::shared_ptr<Schema> filtered_schema;
    if (!inclusion_mask_.empty()) {
      FieldVector filtered_fields;
      for (int i = 0; i < schema_->num_fields(); ++i) {
        if (inclusion_mask_[i]) {
          filtered_fields.push_back(schema_->field(i));
        }
      }
      filtered_schema = schema(std::move(filtered_fields), schema_->metadata());
    } else {
      filtered_schema = schema_;
    }

    return RecordBatch::Make(std::move(filtered_schema), batch_length_,
                             std::move(filtered_columns));
  }

  Result<ArrayDataVector> CreateColumns(ArrayDataVector columns,
                                        bool resolve_dictionaries = true) {