Types.h File Reference

#include <cstdint>
#include <vector>
#include <memory>
#include <mutex>
#include <unordered_map>
#include <queue>
#include "Utils/concurrentqueue.h"
#include "Utils/DupicatedHashTable.hpp"
#include "Utils/SafeQueue.hpp"
#include "Utils/SPSCQueue.hpp"

Include dependency graph for Types.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
class	INTELLI::Tuple
	The class to describe a tuple. More...
class	INTELLI::RelationCouple
class	INTELLI::WindowCouple
class	INTELLI::ConcurrentQWindowCouple
class	INTELLI::Result

Namespaces
	INTELLI

Macros
#define	UNUSED(x)   (void)(x)
#define	ALGO_NAME   "CellJoin"
#define	ALGO_CLASS   CellJoin
#define	WINDOW_SIZE   500
#define	THREAD_NUMBER   2
#define	TIME_STEP   20
#define	DATASET_NAME   "Test1"
#define	newTuplePtrQueue(n)   make_shared<INTELLI::SPSCQueue<INTELLI::TuplePtr>>(n)
	To create a new TuplePtrQueue. More...
#define	newWindowQueue(n)   make_shared<INTELLI::SPSCQueue<WindowOfTuples>>(n)
#define	newCmdQueue(n)   make_shared<INTELLI::SPSCQueue<INTELLI::join_cmd_t>>(n)

Typedefs
typedef uint64_t	INTELLI::keyType
typedef uint64_t	INTELLI::valueType
typedef int	INTELLI::numberType
typedef std::mutex	INTELLI::mutex
typedef INTELLI::DupicatedHashTable< keyType, keyType >	INTELLI::hashtable
typedef std::queue< numberType >	INTELLI::tupleKeyQueue
typedef std::shared_ptr< class Tuple >	INTELLI::TuplePtr
	The class to describe a shared pointer to Tuple. More...
typedef std::shared_ptr< class RelationCouple >	INTELLI::RelationCouplePtr
typedef std::shared_ptr< std::barrier<> >	INTELLI::BarrierPtr
typedef std::vector< TuplePtr >	INTELLI::WindowOfTuples
typedef std::queue< TuplePtr >	INTELLI::TuplePtrQueueIn
	To describe a local queue of TuplePtr. More...
typedef moodycamel::ConcurrentQueue< TuplePtr >	INTELLI::concurrentTupleQueue
typedef std::shared_ptr< INTELLI::SPSCQueue< INTELLI::TuplePtr > >	INTELLI::TuplePtrQueue
	To describe a queue of TuplePtr under SPSCQueue. More...
typedef std::shared_ptr< std::queue< INTELLI::TuplePtr > >	INTELLI::TupleQueueSelfPtr
typedef std::shared_ptr< INTELLI::SPSCQueue< vector< INTELLI::TuplePtr > > >	INTELLI::WindowQueue
typedef std::shared_ptr< INTELLI::SPSCQueue< INTELLI::join_cmd_t > >	INTELLI::CmdQueuePtr

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 }