duckdb::SimpleBufferedData Class Reference

Inheritance diagram for duckdb::SimpleBufferedData:

Collaboration diagram for duckdb::SimpleBufferedData:

Public Member Functions
	SimpleBufferedData (ClientContext &context)
void	Append (const DataChunk &chunk)
void	BlockSink (const InterruptState &blocked_sink)
bool	BufferIsFull ()
void	UnblockSinks () override
StreamExecutionResult	ExecuteTaskInternal (StreamQueryResult &result, ClientContextLock &context_lock) override
unique_ptr< DataChunk >	Scan () override
idx_t	BufferSize () const
Public Member Functions inherited from duckdb::BufferedData
	BufferedData (Type type, ClientContext &context)
StreamExecutionResult	ReplenishBuffer (StreamQueryResult &result, ClientContextLock &context_lock)
shared_ptr< ClientContext >	GetContext ()
bool	Closed () const
void	Close ()
template<class TARGET >
TARGET &	Cast ()
template<class TARGET >
const TARGET &	Cast () const

Static Public Attributes
static constexpr const BufferedData::Type	TYPE = BufferedData::Type::SIMPLE

Private Attributes
queue< InterruptState >	blocked_sinks
	Our handles to reschedule the blocked sink tasks.
queue< unique_ptr< DataChunk > >	buffered_chunks
	The queue of chunks.
atomic< idx_t >	buffered_count
	The current capacity of the buffer (tuples)
idx_t	buffer_size
	The amount of tuples we should buffer.

Additional Inherited Members
Protected Types inherited from duckdb::BufferedData
enum class	Type { SIMPLE , BATCHED }
Protected Attributes inherited from duckdb::BufferedData
Type	type
weak_ptr< ClientContext >	context
	This is weak to avoid a cyclical reference.
idx_t	total_buffer_size
	The maximum amount of memory we should keep buffered.
mutex	glock
	Protect against populate/fetch race condition.

Member Function Documentation

UnblockSinks()

void duckdb::SimpleBufferedData::UnblockSinks ( )

overridevirtual

Implements duckdb::BufferedData.

ExecuteTaskInternal()

StreamExecutionResult duckdb::SimpleBufferedData::ExecuteTaskInternal ( StreamQueryResult &  result, ClientContextLock &  context_lock  )

overridevirtual

Implements duckdb::BufferedData.

Scan()

unique_ptr< DataChunk > duckdb::SimpleBufferedData::Scan ( )

overridevirtual

Implements duckdb::BufferedData.

BufferSize()

idx_t duckdb::SimpleBufferedData::BufferSize ( ) const

inline

                                    {
        return buffer_size;
    }

---

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

• external/duckdb/duckdb.hpp