MCPcopy Create free account
hub / github.com/apache/cloudberry / ExecParallelHashFirstTuple

Function ExecParallelHashFirstTuple

src/backend/executor/nodeHash.c:3932–3943  ·  view source on GitHub ↗

* Get the first tuple in a given bucket identified by number. */

Source from the content-addressed store, hash-verified

3930 * Get the first tuple in a given bucket identified by number.
3931 */
3932static inline HashJoinTuple
3933ExecParallelHashFirstTuple(HashJoinTable hashtable, int bucketno)
3934{
3935 HashJoinTuple tuple;
3936 dsa_pointer p;
3937
3938 Assert(hashtable->parallel_state);
3939 p = dsa_pointer_atomic_read(&hashtable->buckets.shared[bucketno]);
3940 tuple = (HashJoinTuple) dsa_get_address(hashtable->area, p);
3941
3942 return tuple;
3943}
3944
3945/*
3946 * Get the next tuple in the same bucket as 'tuple'.

Callers 1

Calls 1

dsa_get_addressFunction · 0.85

Tested by

no test coverage detected