35#define SH_PREFIX tuplehash
36#define SH_ELEMENT_TYPE TupleHashEntryData
37#define SH_KEY_TYPE MinimalTuple
38#define SH_KEY firstTuple
39#define SH_HASH_KEY(tb, key) TupleHashTableHash_internal(tb, key)
40#define SH_EQUAL(tb, a, b) TupleHashTableMatch(tb, a, b) == 0
41#define SH_SCOPE extern
43#define SH_GET_HASH(tb, a) a->hash
61 const Oid *eqOperators,
62 const Oid *collations,
75 for (
i = 0;
i < numCols;
i++)
80 numCols, keyColIdx, eqFunctions, collations,
98 const Oid *eqOperators,
107 for (
i = 0;
i < numCols;
i++)
109 Oid eq_opr = eqOperators[
i];
111 Oid left_hash_function;
112 Oid right_hash_function;
116 &left_hash_function, &right_hash_function))
117 elog(
ERROR,
"could not find hash function for hash operator %u",
120 Assert(left_hash_function == right_hash_function);
121 (*eqFuncOids)[
i] = eq_function;
122 fmgr_info(right_hash_function, &(*hashFunctions)[
i]);
166 const Oid *eqfuncoids,
174 bool use_variable_hash_iv)
187 if (nbuckets > hash_mem_limit)
188 nbuckets = hash_mem_limit;
212 if (use_variable_hash_iv)
215 hashtable->
hashtab = tuplehash_create(metacxt, nbuckets, hashtable);
232 allow_jit = (metacxt != tablecxt);
241 allow_jit ? parent : NULL,
249 keyColIdx, eqfuncoids, collations,
250 allow_jit ? parent : NULL);
273 tuplehash_reset(hashtable->
hashtab);
313 Assert(entry == NULL || entry->
hash == local_hash);
397 entry = tuplehash_lookup(hashtable->
hashtab,
key);
471 entry = tuplehash_insert_hash(hashtable->
hashtab,
key,
hash, &found);
521 econtext->ecxt_innertuple = slot2;
522 econtext->ecxt_outertuple = slot1;
#define Assert(condition)
ExprState * ExecBuildHash32FromAttrs(TupleDesc desc, const TupleTableSlotOps *ops, FmgrInfo *hashfunctions, Oid *collations, int numCols, AttrNumber *keyColIdx, PlanState *parent, uint32 init_value)
ExprState * ExecBuildGroupingEqual(TupleDesc ldesc, TupleDesc rdesc, const TupleTableSlotOps *lops, const TupleTableSlotOps *rops, int numCols, const AttrNumber *keyColIdx, const Oid *eqfunctions, const Oid *collations, PlanState *parent)
ExprState * execTuplesMatchPrepare(TupleDesc desc, int numCols, const AttrNumber *keyColIdx, const Oid *eqOperators, const Oid *collations, PlanState *parent)
void execTuplesHashPrepare(int numCols, const Oid *eqOperators, Oid **eqFuncOids, FmgrInfo **hashFunctions)
TupleHashEntry LookupTupleHashEntryHash(TupleHashTable hashtable, TupleTableSlot *slot, bool *isnew, uint32 hash)
TupleHashEntry LookupTupleHashEntry(TupleHashTable hashtable, TupleTableSlot *slot, bool *isnew, uint32 *hash)
static uint32 TupleHashTableHash_internal(struct tuplehash_hash *tb, const MinimalTuple tuple)
uint32 TupleHashTableHash(TupleHashTable hashtable, TupleTableSlot *slot)
TupleHashEntry FindTupleHashEntry(TupleHashTable hashtable, TupleTableSlot *slot, ExprState *eqcomp, ExprState *hashexpr)
static int TupleHashTableMatch(struct tuplehash_hash *tb, const MinimalTuple tuple1, const MinimalTuple tuple2)
TupleHashTable BuildTupleHashTable(PlanState *parent, TupleDesc inputDesc, const TupleTableSlotOps *inputOps, int numCols, AttrNumber *keyColIdx, const Oid *eqfuncoids, FmgrInfo *hashfunctions, Oid *collations, long nbuckets, Size additionalsize, MemoryContext metacxt, MemoryContext tablecxt, MemoryContext tempcxt, bool use_variable_hash_iv)
void ResetTupleHashTable(TupleHashTable hashtable)
static TupleHashEntry LookupTupleHashEntry_internal(TupleHashTable hashtable, TupleTableSlot *slot, bool *isnew, uint32 hash)
TupleTableSlot * MakeSingleTupleTableSlot(TupleDesc tupdesc, const TupleTableSlotOps *tts_ops)
TupleTableSlot * ExecStoreMinimalTuple(MinimalTuple mtup, TupleTableSlot *slot, bool shouldFree)
const TupleTableSlotOps TTSOpsMinimalTuple
ExprContext * CreateStandaloneExprContext(void)
struct TupleHashTableData * TupleHashTable
struct TupleHashEntryData TupleHashEntryData
static bool ExecQualAndReset(ExprState *state, ExprContext *econtext)
static Datum ExecEvalExpr(ExprState *state, ExprContext *econtext, bool *isNull)
void fmgr_info(Oid functionId, FmgrInfo *finfo)
static uint32 murmurhash32(uint32 data)
if(TABLE==NULL||TABLE_index==NULL)
RegProcedure get_opcode(Oid opno)
bool get_op_hash_functions(Oid opno, RegProcedure *lhs_procno, RegProcedure *rhs_procno)
size_t get_hash_memory_limit(void)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
static uint32 DatumGetUInt32(Datum X)
static unsigned hash(unsigned *uv, int n)
TupleTableSlot * ecxt_innertuple
ExprState * tab_hash_expr
TupleTableSlot * tableslot
ExprContext * exprcontext
TupleTableSlot * inputslot
TupleDesc CreateTupleDescCopy(TupleDesc tupdesc)
static MinimalTuple ExecCopySlotMinimalTuple(TupleTableSlot *slot)