duckdb::ArrowArrayStreamWrapper Class Reference

Collaboration diagram for duckdb::ArrowArrayStreamWrapper:

Public Member Functions
void	GetSchema (ArrowSchemaWrapper &schema)
virtual shared_ptr< ArrowArrayWrapper >	GetNextChunk ()
const char *	GetError ()

Public Attributes
ArrowArrayStream	arrow_array_stream
int64_t	number_of_rows

Constructor & Destructor Documentation

~ArrowArrayStreamWrapper()

duckdb::ArrowArrayStreamWrapper::~ArrowArrayStreamWrapper ( )

virtual

                                                  {
    if (arrow_array_stream.release) {
        arrow_array_stream.release(&arrow_array_stream);
        D_ASSERT(!arrow_array_stream.release);
    }
}

ArrowArrayStreamWrapper()

duckdb::ArrowArrayStreamWrapper::ArrowArrayStreamWrapper ( )

inline

                              {
        arrow_array_stream.release = nullptr;
    }

Member Function Documentation

GetSchema()

void duckdb::ArrowArrayStreamWrapper::GetSchema

(

ArrowSchemaWrapper &

schema

)

                                                                  {
    D_ASSERT(arrow_array_stream.get_schema);
    // LCOV_EXCL_START
    if (arrow_array_stream.get_schema(&arrow_array_stream, &schema.arrow_schema)) {
        throw InvalidInputException("arrow_scan: get_schema failed(): %s", string(GetError()));
    }
    if (!schema.arrow_schema.release) {
        throw InvalidInputException("arrow_scan: released schema passed");
    }
    if (schema.arrow_schema.n_children < 1) {
        throw InvalidInputException("arrow_scan: empty schema passed");
    }
    // LCOV_EXCL_STOP
}

GetNextChunk()

shared_ptr< ArrowArrayWrapper > duckdb::ArrowArrayStreamWrapper::GetNextChunk ( )

virtual

                                                                    {
    auto current_chunk = make_shared_ptr<ArrowArrayWrapper>();
    if (arrow_array_stream.get_next(&arrow_array_stream, &current_chunk->arrow_array)) { // LCOV_EXCL_START
        throw InvalidInputException("arrow_scan: get_next failed(): %s", string(GetError()));
    } // LCOV_EXCL_STOP
 
    return current_chunk;
}

GetError()

const char * duckdb::ArrowArrayStreamWrapper::GetError

(

)

                                              { // LCOV_EXCL_START
    return arrow_array_stream.get_last_error(&arrow_array_stream);
} // LCOV_EXCL_STOP

---

The documentation for this class was generated from the following files:

• external/duckdb/duckdb.hpp
• external/duckdb/duckdb.cpp