Method joinAll

publication/source_code/bench_end_to_end/src/vectorwise/Operators.cpp:126–160

}

pos_t Hashjoin::joinAll() {
	size_t found = 0;
	// perform continuation
	for (auto entry = cont.buildMatch; entry != shared.ht.end(); entry = entry->next) {
		if (entry->hash == cont.probeHash) {
			buildMatches[found]   = entry;
			probeMatches[found++] = cont.nextProbe;
			if (found == batchSize) {
				// output buffers are full, save state for continuation
				cont.buildMatch = entry->next;
				return batchSize;
			}
		}
	}
	if (cont.buildMatch != shared.ht.end()) cont.nextProbe++;
	for (size_t i = cont.nextProbe, end = cont.numProbes; i < end; ++i) {
		auto hash = probeHashes[i];
		for (auto entry = shared.ht.find_chain_tagged(hash); entry != shared.ht.end(); entry = entry->next) {
			if (entry->hash == hash) {
				buildMatches[found]   = entry;
				probeMatches[found++] = i;
				if (found == batchSize && (entry->next || i + 1 < end)) {
					// output buffers are full, save state for continuation
					cont.buildMatch = entry->next;
					cont.probeHash  = hash;
					cont.nextProbe  = i;
					return batchSize;
				}
			}
		}
	}
	cont.buildMatch = shared.ht.end();
	cont.nextProbe  = cont.numProbes;
	return found;
}

pos_t Hashjoin::joinAllParallel() {
	size_t found         = 0;