duckdb::ArrowScalarBaseData< TGT, SRC, OP > Struct Template Reference

Inheritance diagram for duckdb::ArrowScalarBaseData< TGT, SRC, OP >:

Static Public Member Functions
static void	Append (ArrowAppendData &append_data, Vector &input, idx_t from, idx_t to, idx_t input_size)

Member Function Documentation

Append()

template<class TGT , class SRC = TGT, class OP = ArrowScalarConverter>

static void duckdb::ArrowScalarBaseData< TGT, SRC, OP >::Append ( ArrowAppendData &  append_data, Vector &  input, idx_t  from, idx_t  to, idx_t  input_size  )

inlinestatic

                                                                                                            {
        D_ASSERT(to >= from);
        idx_t size = to - from;
        D_ASSERT(size <= input_size);
        UnifiedVectorFormat format;
        input.ToUnifiedFormat(input_size, format);
 
        // append the validity mask
        append_data.AppendValidity(format, from, to);
 
        // append the main data
        auto &main_buffer = append_data.GetMainBuffer();
        main_buffer.resize(main_buffer.size() + sizeof(TGT) * size);
        auto data = UnifiedVectorFormat::GetData<SRC>(format);
        auto result_data = main_buffer.GetData<TGT>();
 
        for (idx_t i = from; i < to; i++) {
            auto source_idx = format.sel->get_index(i);
            auto result_idx = append_data.row_count + i - from;
 
            if (OP::SkipNulls() && !format.validity.RowIsValid(source_idx)) {
                OP::template SetNull<TGT>(result_data[result_idx]);
                continue;
            }
            result_data[result_idx] = OP::template Operation<TGT, SRC>(data[source_idx]);
        }
        append_data.row_count += size;
    }

---

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

• external/duckdb/duckdb.cpp