Classes | |
class | DatasetTool |
The class containing methods to process dataset. More... | |
class | MtBucket |
The multithread-supported bucket. More... | |
class | MultiThreadHashTable |
The multithread-supported hash table, holding buckets. More... | |
class | Tuple |
The class to describe a tuple. More... | |
class | RelationCouple |
class | WindowCouple |
class | ConcurrentQWindowCouple |
class | Result |
class | VerifyBench |
class | AbstractJoinAlgo |
The abstraction to describe a join algorithm, providing virtual function of join. More... | |
class | JoinAlgoTable |
The table contains all supported algos. More... | |
class | NestedLoopJoin |
The top class package of Nested Loop Join providing a "join function". More... | |
class | NPJ_thread |
The thread used by NPJ. More... | |
class | NPJ |
The top class package of NPJ, providing a "join function". More... | |
class | NPJSingle |
The top class package of single threadNPJ, providing a "join function". More... | |
class | AbstractJP |
The basic class of join processor. More... | |
class | AbstractLazyJP |
The basic class of lazy join processor. More... | |
class | CellJoinJP |
The class of cell join join processor. More... | |
class | HandShakeJP |
class | SplitJoinIRJP |
The class of split join join processor, which also shares the intermediate results (IR) More... | |
class | SplitJoinJP |
The class of split join join processor. More... | |
class | AbstractC20Thread |
The base class and abstraction of C++20 thread, and it can be derived into other threads. More... | |
class | C20Buffer |
class | DupicatedHashTable |
class | MicroDataSet |
The all-in-one class for the Micro dataset. More... | |
class | SPSCQueue |
class | PerfEntry |
class | PerfTool |
pack the perf event in cpp style, remain safe if some std linux perf failed More... | |
class | PerfPair |
Combine PerfTool together with tags. More... | |
class | ThreadPerf |
The all-in-on perf class for thread. More... | |
class | UtilityFunctions |
class | AbstractEagerWS |
An abstraction of eager window slider (i.e., the CellJoin), also inherited by other eager window slider. More... | |
class | AbstractLazyWS |
An abstraction of lazy window slider, also inherited by other lazy window slider. More... | |
class | AbstractWS |
An abstraction of window slider, also inherited by both eager and lazy. More... | |
class | HandShakeWS |
The eager window slider of handshake join. More... | |
class | SplitJoinIRWS |
The eager window slider of split join, which also shares the intermediate results (IR) More... | |
class | SplitJoinWS |
The eager window slider of split join. More... | |
class | VerifyWS |
The single-thread window slider used for verify results of other WS. More... | |
class | AbstractJoinMethod |
class | CellJoin |
class | HandShakeJoin |
class | OneWayHashJoin |
Typedefs | |
typedef std::shared_ptr< MtBucket > | MtBucketPtr |
typedef TuplePtr | MtTuplePtr |
typedef std::shared_ptr< MultiThreadHashTable > | MultiThreadHashTablePtr |
typedef uint64_t | keyType |
typedef uint64_t | valueType |
typedef int | numberType |
typedef std::mutex | mutex |
typedef INTELLI::DupicatedHashTable< keyType, keyType > | hashtable |
typedef std::queue< numberType > | tupleKeyQueue |
typedef std::shared_ptr< class Tuple > | TuplePtr |
The class to describe a shared pointer to Tuple. More... | |
typedef std::shared_ptr< class RelationCouple > | RelationCouplePtr |
typedef std::shared_ptr< std::barrier<> > | BarrierPtr |
typedef std::vector< TuplePtr > | WindowOfTuples |
typedef std::queue< TuplePtr > | TuplePtrQueueIn |
To describe a local queue of TuplePtr. More... | |
typedef moodycamel::ConcurrentQueue< TuplePtr > | concurrentTupleQueue |
typedef std::shared_ptr< INTELLI::SPSCQueue< INTELLI::TuplePtr > > | TuplePtrQueue |
To describe a queue of TuplePtr under SPSCQueue. More... | |
typedef std::shared_ptr< std::queue< INTELLI::TuplePtr > > | TupleQueueSelfPtr |
typedef std::shared_ptr< INTELLI::SPSCQueue< vector< INTELLI::TuplePtr > > > | WindowQueue |
typedef std::shared_ptr< INTELLI::SPSCQueue< INTELLI::join_cmd_t > > | CmdQueuePtr |
typedef std::shared_ptr< AbstractJoinAlgo > | AbstractJoinAlgoPtr |
typedef std::shared_ptr< JoinAlgoTable > | JoinAlgoTablePtr |
typedef std::shared_ptr< NestedLoopJoin > | NestedLoopJoinPtr |
typedef std::shared_ptr< AbstractLazyJP > | AbstractLazyJPPtr |
typedef std::shared_ptr< CellJoinJP > | CellJoinJPPtr |
typedef std::shared_ptr< HandShakeJP > | HandShakeJPPtr |
typedef INTELLI::DupicatedHashTable< keyType, keyType > | dpHashtable |
typedef shared_ptr< dpHashtable > | dpHashtablePtr |
typedef std::shared_ptr< SplitJoinIRJP > | SplitJoinIRJPPtr |
typedef std::shared_ptr< SplitJoinJP > | SplitJoinJPPtr |
typedef std::shared_ptr< PerfTool > | PerfToolPtr |
typedef enum INTELLI::perfTrace | perfIdx |
typedef std::shared_ptr< NPJ > | NPJPtr |
typedef std::shared_ptr< NPJSingle > | NPJSinglePtr |
Enumerations | |
enum | join_type_t { CNT_BASED = 1 , TIME_STAMP_BASED = 2 } |
enum | join_cmd_t { CMD_ACK = 1 , CMD_STOP = 2 , CMD_NEXT_WSTR , CMD_NEXT_WSTS , CMD_NEXT_TSWR , CMD_NEXT_TSTR , CMD_NEXT_TS_ONLY , CMD_NEXT_TR_ONLY } |
enum | join_algo_index_t { JOINALGO_NULL = 0 , JOINALGO_NESTEDLOOP = 1 , JOINALGO_NPJ = 2 , JOINALGO_NPJ_SINGLE = 3 } |
The system default index for join algorithms. More... | |
enum | lwj_status_t { LWJ_IDLE = 0 , LWJ_COLLECTING , LWJ_PROCESSING } |
The status of lazy join processor. More... | |
enum | perfTrace { TRACE_RUNNING_TIME = -1 , COUNT_SW_CPU_CLOCK = 0 , COUNT_SW_TASK_CLOCK = 1 , COUNT_SW_CONTEXT_SWITCHES = 2 , COUNT_SW_CPU_MIGRATIONS = 3 , COUNT_SW_PAGE_FAULTS = 4 , COUNT_SW_PAGE_FAULTS_MIN = 5 , COUNT_SW_PAGE_FAULTS_MAJ = 6 , COUNT_HW_CPU_CYCLES = 7 , COUNT_HW_INSTRUCTIONS = 8 , COUNT_HW_CACHE_REFERENCES = 9 , COUNT_HW_CACHE_MISSES = 10 , COUNT_HW_BRANCH_INSTRUCTIONS = 11 , COUNT_HW_BRANCH_MISSES = 12 , COUNT_HW_BUS_CYCLES = 13 , COUNT_HW_CACHE_L1D_LOADS = 14 , COUNT_HW_CACHE_L1D_LOADS_MISSES = 15 , COUNT_HW_CACHE_L1D_STORES = 16 , COUNT_HW_CACHE_L1D_STORES_MISSES = 17 , COUNT_HW_CACHE_L1D_PREFETCHES = 18 , COUNT_HW_CACHE_L1I_LOADS = 19 , COUNT_HW_CACHE_L1I_LOADS_MISSES = 20 , COUNT_HW_CACHE_LL_LOADS = 21 , COUNT_HW_CACHE_LL_LOADS_MISSES = 22 , COUNT_HW_CACHE_LL_STORES = 23 , COUNT_HW_CACHE_LL_STORES_MISSES = 24 , COUNT_HW_CACHE_DTLB_LOADS = 25 , COUNT_HW_CACHE_DTLB_LOADS_MISSES = 26 , COUNT_HW_CACHE_DTLB_STORES = 27 , COUNT_HW_CACHE_DTLB_STORES_MISSES = 28 , COUNT_HW_CACHE_ITLB_LOADS = 29 , COUNT_HW_CACHE_ITLB_LOADS_MISSES = 30 , COUNT_HW_CACHE_BPU_LOADS = 31 , COUNT_HW_CACHE_BPU_LOADS_MISSES = 32 } |
The valid idx for perf. More... | |
This group provides common functions to support the Intelli Stream programs. ++20
This package covers some common C++20 new features, such as std::thread to ease the programming