Adaptive distribution for hash operations

A system comprising:

• a memory;
• and
• a processing device, operatively coupled to the memory, the processing device to:
• receive a relational join query for a join operation associated with a first relation and a second relation;
• generate at least one build operator and at least one probe operator to perform build operations and probe operations, respectively, of the join operation;
• and
• manage a state of one or more communication links between the at least one build operator and the at least one probe operator based on a size of the second relation as determined by the at least one build operator and an estimated size of the first relation.

A non-transitory computer readable medium having instructions stored thereon that, when executed by a processing device, cause the processing device to:

• receive a relational join query for a join operation associated with a first relation and a second relation;
• generate at least one build operator and at least one probe operator to perform build operations and probe operations, respectively, of the join operation;
• and
• manage a state of one or more communication links between the at least one build operator and the at least one probe operator based on a size of the second relation as determined by the at least one build operator and an estimated size of the first relation.