duckdb::ArrowStructData Struct Reference

Static Public Member Functions
static void	Initialize (ArrowAppendData &result, const LogicalType &type, idx_t capacity)
static void	Append (ArrowAppendData &append_data, Vector &input, idx_t from, idx_t to, idx_t input_size)
static void	Finalize (ArrowAppendData &append_data, const LogicalType &type, ArrowArray *result)

Member Function Documentation

Initialize()

void duckdb::ArrowStructData::Initialize ( ArrowAppendData &  result, const LogicalType &  type, idx_t  capacity  )

static

                                                                                                 {
    auto &children = StructType::GetChildTypes(type);
    for (auto &child : children) {
        auto child_buffer = ArrowAppender::InitializeChild(child.second, capacity, result.options);
        result.child_data.push_back(std::move(child_buffer));
    }
}

Append()

void duckdb::ArrowStructData::Append ( ArrowAppendData &  append_data, Vector &  input, idx_t  from, idx_t  to, idx_t  input_size  )

static

                                                                                                                {
    UnifiedVectorFormat format;
    input.ToUnifiedFormat(input_size, format);
    idx_t size = to - from;
    append_data.AppendValidity(format, from, to);
    // append the children of the struct
    auto &children = StructVector::GetEntries(input);
    for (idx_t child_idx = 0; child_idx < children.size(); child_idx++) {
        auto &child = children[child_idx];
        auto &child_data = *append_data.child_data[child_idx];
        child_data.append_vector(child_data, *child, from, to, size);
    }
    append_data.row_count += size;
}

Finalize()

void duckdb::ArrowStructData::Finalize ( ArrowAppendData &  append_data, const LogicalType &  type, ArrowArray *  result  )

static

                                                                                                        {
    result->n_buffers = 1;
 
    auto &child_types = StructType::GetChildTypes(type);
    ArrowAppender::AddChildren(append_data, child_types.size());
    result->children = append_data.child_pointers.data();
    result->n_children = NumericCast<int64_t>(child_types.size());
    for (idx_t i = 0; i < child_types.size(); i++) {
        auto &child_type = child_types[i].second;
        append_data.child_arrays[i] = *ArrowAppender::FinalizeChild(child_type, std::move(append_data.child_data[i]));
    }
}

---

The documentation for this struct was generated from the following file:

• external/duckdb/duckdb.cpp