|
Multi-core Hash Joins
Main-memory hash join implementations for multi-core CPUs
|
Public Attributes | |
| int32_t | tid |
| hashtable_t * | ht |
| relation_t | relR |
| relation_t | relS |
| pthread_barrier_t * | barrier |
| int64_t | num_results |
| threadresult_t * | threadresult |
| uint64_t | timer1 |
| uint64_t | timer2 |
| uint64_t | timer3 |
| struct timeval start | end |
| int32_t ** | histR |
| tuple_t * | relR |
| tuple_t * | tmpR |
| int32_t ** | histS |
| tuple_t * | relS |
| tuple_t * | tmpS |
| int32_t | numR |
| int32_t | numS |
| int64_t | totalR |
| int64_t | totalS |
| task_queue_t ** | join_queue |
| task_queue_t ** | part_queue |
| JoinFunction | join_function |
| int64_t | result |
| int32_t | my_tid |
| int | nthreads |
| int32_t | parts_processed |
holds the arguments passed to each thread
Definition at line 90 of file no_partitioning_join.c.
| pthread_barrier_t * arg_t::barrier |
Definition at line 95 of file no_partitioning_join.c.
| struct timeval start arg_t::end |
Definition at line 104 of file no_partitioning_join.c.
| int32_t** arg_t::histR |
Definition at line 153 of file parallel_radix_join.c.
| int32_t** arg_t::histS |
Definition at line 156 of file parallel_radix_join.c.
| hashtable_t* arg_t::ht |
Definition at line 92 of file no_partitioning_join.c.
| JoinFunction arg_t::join_function |
Definition at line 172 of file parallel_radix_join.c.
| task_queue_t** arg_t::join_queue |
Definition at line 165 of file parallel_radix_join.c.
| int32_t arg_t::my_tid |
Definition at line 174 of file parallel_radix_join.c.
| int arg_t::nthreads |
Definition at line 175 of file parallel_radix_join.c.
| int64_t arg_t::num_results |
Definition at line 96 of file no_partitioning_join.c.
| int32_t arg_t::numR |
Definition at line 160 of file parallel_radix_join.c.
| int32_t arg_t::numS |
Definition at line 161 of file parallel_radix_join.c.
| task_queue_t** arg_t::part_queue |
Definition at line 166 of file parallel_radix_join.c.
| int32_t arg_t::parts_processed |
Definition at line 181 of file parallel_radix_join.c.
| relation_t arg_t::relR |
Definition at line 93 of file no_partitioning_join.c.
| tuple_t* arg_t::relR |
Definition at line 154 of file parallel_radix_join.c.
| relation_t arg_t::relS |
Definition at line 94 of file no_partitioning_join.c.
| tuple_t* arg_t::relS |
Definition at line 157 of file parallel_radix_join.c.
| int64_t arg_t::result |
Definition at line 173 of file parallel_radix_join.c.
| threadresult_t * arg_t::threadresult |
Definition at line 99 of file no_partitioning_join.c.
| int32_t arg_t::tid |
Definition at line 91 of file no_partitioning_join.c.
| uint64_t arg_t::timer1 |
Definition at line 103 of file no_partitioning_join.c.
| uint64_t arg_t::timer2 |
Definition at line 103 of file no_partitioning_join.c.
| uint64_t arg_t::timer3 |
Definition at line 103 of file no_partitioning_join.c.
| tuple_t* arg_t::tmpR |
Definition at line 155 of file parallel_radix_join.c.
| tuple_t* arg_t::tmpS |
Definition at line 158 of file parallel_radix_join.c.
| int64_t arg_t::totalR |
Definition at line 162 of file parallel_radix_join.c.
| int64_t arg_t::totalS |
Definition at line 163 of file parallel_radix_join.c.