The top class package of Nested Loop Join providing a "join function".
More...
#include <NestedLoopJoin.h>
|
virtual size_t | join (TuplePtr *ts, TuplePtr *tr, size_t tsLen, size_t trLen, int threads=1) |
| The function to execute join, legacy way. More...
|
|
virtual size_t | join (TuplePtr *ts, TuplePtr tr, size_t tsLen, int threads=1) |
| The function to execute join, batch of one, tuple of another. More...
|
|
virtual size_t | join (TuplePtrQueue ts, TuplePtrQueue tr, int threads=1) |
| The function to execute join, batch of both. More...
|
|
virtual size_t | join (TuplePtrQueue ts, TuplePtr tr, int threads=1) |
| The function to execute join, batch of one, tuple of another. More...
|
|
void | setAlgoName (string name) |
| set the name of algorithm More...
|
|
string | getAlgoName () |
| get the name of algorithm More...
|
|
The top class package of Nested Loop Join providing a "join function".
- Note
- Just single thread, the threads parameter is useless
◆ join() [1/4]
virtual size_t INTELLI::NestedLoopJoin::join |
( |
TuplePtr * |
ts, |
|
|
TuplePtr * |
tr, |
|
|
size_t |
tsLen, |
|
|
size_t |
trLen, |
|
|
int |
threads = 1 |
|
) |
| |
|
virtual |
The function to execute join, legacy way.
- Parameters
-
ts | The tuples of stream S, legacy pointer |
tr | The tuples of stream R, legacy pointer |
tsLen | The length of S |
trLen | The length of R |
threads | The parallel threads |
- Returns
- The joined tuples
- Warning
- This is a legacy function, avoid using it if possible
Reimplemented from INTELLI::AbstractJoinAlgo.
◆ join() [2/4]
virtual size_t INTELLI::NestedLoopJoin::join |
( |
TuplePtr * |
ts, |
|
|
TuplePtr |
tr, |
|
|
size_t |
tsLen, |
|
|
int |
threads = 1 |
|
) |
| |
|
virtual |
The function to execute join, batch of one, tuple of another.
- Parameters
-
ts | The tuples of stream S, legacy pointer |
tr | The tuples of stream R, one tuple |
tsLen | The length of S |
threads | The parallel threads |
- Returns
- The joined tuples
- Warning
- This is a legacy function, avoid using it if possible
Reimplemented from INTELLI::AbstractJoinAlgo.
◆ join() [3/4]
The function to execute join, batch of one, tuple of another.
- Parameters
-
ts | The tuples of stream S |
tr | The tuple of stream R |
threads | The parallel threads |
- Returns
- The joined tuples
Reimplemented from INTELLI::AbstractJoinAlgo.
◆ join() [4/4]
The function to execute join, batch of both.
- Parameters
-
ts | The tuples of stream S |
tr | The tuples of stream R |
threads | The parallel threads |
- Returns
- The joined tuples
- Todo:
- Add AMP and NUMA support in the future, so far only generic SMP
Reimplemented from INTELLI::AbstractJoinAlgo.
The documentation for this class was generated from the following file: