duckdb::QueryAppender Class Reference

Inheritance diagram for duckdb::QueryAppender:

Collaboration diagram for duckdb::QueryAppender:

Public Member Functions
DUCKDB_API	QueryAppender (Connection &con, string query, vector< LogicalType > types, vector< string > names=vector< string >(), string table_name=string(), const idx_t flush_memory_threshold=DConstants::INVALID_INDEX)
Public Member Functions inherited from duckdb::BaseAppender
DUCKDB_API void	BeginRow ()
DUCKDB_API void	EndRow ()
	Finishes appending the current row.
template<class T >
void	Append (T value)=delete
DUCKDB_API void	Append (DataChunk &target, const Value &value, idx_t col, idx_t row)
DUCKDB_API void	Append (const char *value, uint32_t length)
template<typename... ARGS>
void	AppendRow (ARGS... args)
DUCKDB_API void	Flush ()
	Commit the changes made by the appender.
DUCKDB_API void	Close ()
	Flush the changes made by the appender and close it. The appender cannot be used after this point.
DUCKDB_API void	Clear ()
	Clears any appended data (without flushing).
const vector< LogicalType > &	GetActiveTypes () const
	Returns the active types of the appender.
idx_t	CurrentColumn () const
DUCKDB_API void	AppendDataChunk (DataChunk &value)
virtual void	AppendDefault ()
virtual void	AppendDefault (DataChunk &chunk, idx_t col, idx_t row)
virtual void	AddColumn (const string &name)
virtual void	ClearColumns ()
template<>
DUCKDB_API void	Append (bool value)
template<>
DUCKDB_API void	Append (int8_t value)
template<>
DUCKDB_API void	Append (int16_t value)
template<>
DUCKDB_API void	Append (int32_t value)
template<>
DUCKDB_API void	Append (int64_t value)
template<>
DUCKDB_API void	Append (hugeint_t value)
template<>
DUCKDB_API void	Append (uhugeint_t value)
template<>
DUCKDB_API void	Append (uint8_t value)
template<>
DUCKDB_API void	Append (uint16_t value)
template<>
DUCKDB_API void	Append (uint32_t value)
template<>
DUCKDB_API void	Append (uint64_t value)
template<>
DUCKDB_API void	Append (float value)
template<>
DUCKDB_API void	Append (double value)
template<>
DUCKDB_API void	Append (date_t value)
template<>
DUCKDB_API void	Append (dtime_t value)
template<>
DUCKDB_API void	Append (timestamp_t value)
template<>
DUCKDB_API void	Append (interval_t value)
template<>
DUCKDB_API void	Append (const char *value)
template<>
DUCKDB_API void	Append (string_t value)
template<>
DUCKDB_API void	Append (Value value)
template<>
DUCKDB_API void	Append (std::nullptr_t value)

Protected Member Functions
void	FlushInternal (ColumnDataCollection &collection) override
Protected Member Functions inherited from duckdb::BaseAppender
DUCKDB_API	BaseAppender (Allocator &allocator, const AppenderType type)
DUCKDB_API	BaseAppender (Allocator &allocator, vector< LogicalType > types, const AppenderType type, const idx_t flush_count=DEFAULT_FLUSH_COUNT)
void	Destructor ()
void	InitializeChunk ()
void	FlushChunk ()
bool	ShouldFlushChunk () const
bool	ShouldFlush () const
template<class T >
void	AppendValueInternal (T value)
template<class SRC , class DST >
void	AppendValueInternal (Vector &vector, SRC input)
template<class SRC , class DST >
void	AppendDecimalValueInternal (Vector &vector, SRC input)
void	AppendRowRecursive ()
template<typename T , typename... ARGS>
void	AppendRowRecursive (T value, ARGS... args)
void	AppendValue (const Value &value)
void	AppendValue (DataChunk target, const Value &value)

Private Attributes
weak_ptr< ClientContext >	context
	A shared pointer to the context of this appender.
string	query
	The query to run.
vector< string >	names
	The column names of the to-be-appended data, or "col1, col2, ...", if empty.
string	table_name
	The table name that we can reference in the query, or "appended_data", if empty.

Additional Inherited Members
Static Public Member Functions inherited from duckdb::BaseAppender
static unique_ptr< TableRef >	GetColumnDataTableRef (ColumnDataCollection &collection, const string &table_name, const vector< string > &expected_names)
	Returns a table reference to the appended data.
static unique_ptr< SQLStatement >	ParseStatement (unique_ptr< TableRef > table_ref, const string &query, const string &table_name)
	Parses the statement to append data.
Static Public Attributes inherited from duckdb::BaseAppender
static constexpr const idx_t	DEFAULT_FLUSH_COUNT = STANDARD_VECTOR_SIZE * 100ULL
	The amount of tuples that are gathered in the column data collection before flushing.
Protected Attributes inherited from duckdb::BaseAppender
Allocator &	allocator
	The allocator for the column data collection.
vector< LogicalType >	types
	The column types of the associated table.
vector< LogicalType >	active_types
	The active column types.
unique_ptr< ColumnDataCollection >	collection
	The buffered to-be-appended data.
DataChunk	chunk
	The active chunk for row-based appends.
idx_t	column = 0
	The currently active column of row-based appends.
AppenderType	appender_type
	The type of the appender.
idx_t	flush_count = DEFAULT_FLUSH_COUNT
	The amount of rows after which the appender flushes automatically.
optional_idx	flush_memory_threshold
	Peak allocation threshold at which to flush the allocator when appender flushs chunk.

Member Function Documentation

FlushInternal()

void duckdb::QueryAppender::FlushInternal ( ColumnDataCollection &  collection )

overrideprotectedvirtual

Implements duckdb::BaseAppender.

---

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

• external/duckdb/duckdb.hpp