| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879 |
- /*-------------------------------------------------------------------------
- *
- * nodeHash.h
- * prototypes for nodeHash.c
- *
- *
- * Portions Copyright (c) 1996-2022, PostgreSQL Global Development Group
- * Portions Copyright (c) 1994, Regents of the University of California
- *
- * src/include/executor/nodeHash.h
- *
- *-------------------------------------------------------------------------
- */
- #ifndef NODEHASH_H
- #define NODEHASH_H
- #include "access/parallel.h"
- #include "nodes/execnodes.h"
- struct SharedHashJoinBatch;
- extern HashState *ExecInitHash(Hash *node, EState *estate, int eflags);
- extern Node *MultiExecHash(HashState *node);
- extern void ExecEndHash(HashState *node);
- extern void ExecReScanHash(HashState *node);
- extern HashJoinTable ExecHashTableCreate(HashState *state, List *hashOperators, List *hashCollations,
- bool keepNulls);
- extern void ExecParallelHashTableAlloc(HashJoinTable hashtable,
- int batchno);
- extern void ExecHashTableDestroy(HashJoinTable hashtable);
- extern void ExecHashTableDetach(HashJoinTable hashtable);
- extern void ExecHashTableDetachBatch(HashJoinTable hashtable);
- extern void ExecParallelHashTableSetCurrentBatch(HashJoinTable hashtable,
- int batchno);
- extern void ExecHashTableInsert(HashJoinTable hashtable,
- TupleTableSlot *slot,
- uint32 hashvalue);
- extern void ExecParallelHashTableInsert(HashJoinTable hashtable,
- TupleTableSlot *slot,
- uint32 hashvalue);
- extern void ExecParallelHashTableInsertCurrentBatch(HashJoinTable hashtable,
- TupleTableSlot *slot,
- uint32 hashvalue);
- extern bool ExecHashGetHashValue(HashJoinTable hashtable,
- ExprContext *econtext,
- List *hashkeys,
- bool outer_tuple,
- bool keep_nulls,
- uint32 *hashvalue);
- extern void ExecHashGetBucketAndBatch(HashJoinTable hashtable,
- uint32 hashvalue,
- int *bucketno,
- int *batchno);
- extern bool ExecScanHashBucket(HashJoinState *hjstate, ExprContext *econtext);
- extern bool ExecParallelScanHashBucket(HashJoinState *hjstate, ExprContext *econtext);
- extern void ExecPrepHashTableForUnmatched(HashJoinState *hjstate);
- extern bool ExecScanHashTableForUnmatched(HashJoinState *hjstate,
- ExprContext *econtext);
- extern void ExecHashTableReset(HashJoinTable hashtable);
- extern void ExecHashTableResetMatchFlags(HashJoinTable hashtable);
- extern void ExecChooseHashTableSize(double ntuples, int tupwidth, bool useskew,
- bool try_combined_hash_mem,
- int parallel_workers,
- size_t *space_allowed,
- int *numbuckets,
- int *numbatches,
- int *num_skew_mcvs);
- extern int ExecHashGetSkewBucket(HashJoinTable hashtable, uint32 hashvalue);
- extern void ExecHashEstimate(HashState *node, ParallelContext *pcxt);
- extern void ExecHashInitializeDSM(HashState *node, ParallelContext *pcxt);
- extern void ExecHashInitializeWorker(HashState *node, ParallelWorkerContext *pwcxt);
- extern void ExecHashRetrieveInstrumentation(HashState *node);
- extern void ExecShutdownHash(HashState *node);
- extern void ExecHashAccumInstrumentation(HashInstrumentation *instrument,
- HashJoinTable hashtable);
- #endif /* NODEHASH_H */
|
