Function makeCsrEdgeBatch

test/api/arrow_drop_table_test.cpp:172–191

}

ArrowArrayWrapper makeCsrEdgeBatch(const std::vector<CsrEdgeRow>& rows) {
    std::vector<uint64_t> offsets;
    std::vector<int64_t> weights;
    std::vector<std::string> labels;
    std::vector<int32_t> since;
    std::vector<std::vector<int64_t>> hops;
    for (const auto& row : rows) {
        offsets.push_back(row.offset);
        weights.push_back(row.weight);
        labels.emplace_back(row.label);
        since.push_back(row.since);
        hops.push_back(row.hops);
    }
    return createStructArray(static_cast<int64_t>(rows.size()),
        {[&](ArrowArray* array) { createUint64Array(array, offsets); },
            [&](ArrowArray* array) { createInt64Array(array, weights); },
            [&](ArrowArray* array) { createStringArray(array, labels); },
            [&](ArrowArray* array) { createDateArray(array, since); },
            [&](ArrowArray* array) { createListInt64Array(array, hops); }});
}

void createPersonTable(main::Connection& connection, const std::string& tableName = "person") {
    std::vector<ArrowArrayWrapper> arrays;