Skip to content
This repository was archived by the owner on Jan 28, 2021. It is now read-only.
This repository was archived by the owner on Jan 28, 2021. It is now read-only.

Partitions: Exchange operator. #312

Closed
@ajnavarro

Description

@ajnavarro

An Exchange will be a Node in charge to parallelize part of the query tree.
The parallelization level will be provided as Analyzer instantiation property.
The Exchange node will basically execute the same part of the tree behind it with a different partition.

Exchange nodes will call to Partitionable.Partitions() method to get the Partition iterator.

It will send that partition to the nethermost node, that must be a Table.
The number of partitions executed at the same time depends on the parallelization provided to the Analyzer.

Exchange node will return EOF when PartitionIter returns EOF and all the executed node threads return EOF.

Metadata

Metadata

Assignees

Labels

enhancementNew feature or request

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions