Collaboration diagram for duckdb::WindowMergeSortTree:

[legend]

Public Types
using	GlobalSortStatePtr = unique_ptr< GlobalSinkState >

using	LocalSortStatePtr = unique_ptr< LocalSinkState >

using	MergeSortTree32 = MergeSortTree< uint32_t, uint32_t >

using	MergeSortTree64 = MergeSortTree< uint64_t, uint64_t >

Public Member Functions
	WindowMergeSortTree (ClientContext &context, const vector< BoundOrderByNode > &orders, const vector< column_t > &order_idx, const idx_t count, bool unique=false)

virtual unique_ptr< LocalSinkState >	GetLocalState (ExecutionContext &context)=0

optional_ptr< LocalSinkState >	InitializeLocalSort (ExecutionContext &context) const
	Make a local sort for a thread.

virtual void	Finished ()
	Thread-safe post-sort cleanup.

bool	TryPrepareSortStage (WindowMergeSortTreeLocalState &lstate)
	Sort state machine.

void	Build ()
	Build the MST in parallel from the sorted data.

Public Attributes
const vector< column_t >	order_idx
	The column indices for sorting.

vector< LogicalType >	scan_types
	The sorted data schema.

vector< idx_t >	scan_cols

vector< idx_t >	key_cols
	The sort key columns.

unique_ptr< Sort >	sort
	The sort specification.

GlobalSortStatePtr	global_sink
	The sorted data.

unique_ptr< ColumnDataCollection >	sorted
	The resulting sorted data.

mutex	lock
	Finalize guard.

vector< LocalSortStatePtr >	local_sinks
	Local sort set.

atomic< WindowMergeSortStage >	build_stage
	Finalize stage.

idx_t	total_tasks = 0
	Tasks launched.

idx_t	tasks_assigned = 0
	Tasks launched.

atomic< idx_t >	tasks_completed
	Tasks landed.

unique_ptr< MergeSortTree32 >	mst32

unique_ptr< MergeSortTree64 >	mst64

Member Function Documentation

◆ MeasurePayloadBlocks()

virtual idx_t duckdb::WindowMergeSortTree::MeasurePayloadBlocks ( )

protectedvirtual

Find the starts of all the blocks Returns the total number of rows

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