An abstraction of window slider, also inherited by both eager and lazy.
More...
#include <AbstractWS.h>
|
INTELLI::join_type_t | myType = INTELLI::CNT_BASED |
|
size_t | countS |
|
size_t | countR |
|
size_t | windowLen = 0 |
|
size_t | slideLen = 1 |
|
std::vector< size_t > | partitionWeight |
|
std::vector< size_t > | partitionSizeFinal |
|
size_t | threads |
|
size_t | sLen |
|
size_t | rLen |
|
bool | runTimeScheduling = false |
|
bool | timeBased = false |
|
bool | isRunning = false |
|
struct timeval | timeSys |
|
TuplePtrQueue | TuplePtrQueueInS |
|
TuplePtrQueue | TuplePtrQueueInR |
|
string | nameTag |
|
An abstraction of window slider, also inherited by both eager and lazy.
Class that is inherited using public inheritance
- Author
- Tony Zeng
- Note
- To init and run, follow the functions below to start a WS
◆ AbstractWS()
INTELLI::AbstractWS::AbstractWS |
( |
size_t |
sLen, |
|
|
size_t |
rLen |
|
) |
| |
to init the slider with specific length of queue
- Parameters
-
sLen | the length of S queue |
rLen | the length of R queue |
◆ feedTupleR()
virtual void INTELLI::AbstractWS::feedTupleR |
( |
TuplePtr |
tr | ) |
|
|
inlinevirtual |
◆ feedTupleS()
virtual void INTELLI::AbstractWS::feedTupleS |
( |
TuplePtr |
ts | ) |
|
|
inlinevirtual |
◆ getJoinResult()
virtual size_t INTELLI::AbstractWS::getJoinResult |
( |
| ) |
|
|
inlinevirtual |
◆ getName()
string INTELLI::AbstractWS::getName |
( |
| ) |
|
|
inline |
get the name of the slider
- Returns
- the nameTag;
◆ getSlideLen()
size_t INTELLI::AbstractWS::getSlideLen |
( |
| ) |
|
|
inline |
get the length of slide
- Returns
- the length of slide
◆ getSysTime()
struct timeval INTELLI::AbstractWS::getSysTime |
( |
| ) |
|
|
inline |
to get the inline timee structure, the timeSys member
- Returns
- the timeSys member
◆ getTimeStamp()
size_t INTELLI::AbstractWS::getTimeStamp |
( |
| ) |
|
|
inline |
to get the time stamp
- Returns
- the time stamp, default in 10 us
◆ initJoinProcessors()
virtual void INTELLI::AbstractWS::initJoinProcessors |
( |
| ) |
|
|
inlinevirtual |
◆ isRunTimeScheduling()
bool INTELLI::AbstractWS::isRunTimeScheduling |
( |
| ) |
|
|
inline |
to read the scheduling type
- Returns
- wether the runtime schedules
◆ isTimeBased()
bool INTELLI::AbstractWS::isTimeBased |
( |
| ) |
|
|
inline |
to read the window type
- Returns
- wether the slider is time-baesd
◆ oldestWindowBelong()
size_t INTELLI::AbstractWS::oldestWindowBelong |
( |
size_t |
ts | ) |
|
|
inlineprotected |
To get the possible oldest a time stamp belongs to.
- Parameters
-
- Returns
- The window number, start from 0
◆ setParallelSMP()
void INTELLI::AbstractWS::setParallelSMP |
( |
size_t |
threads | ) |
|
|
inline |
to set the parallel level under SMP model
- Parameters
-
threads | to how many threads will run the join |
◆ setRunTimeScheduling()
void INTELLI::AbstractWS::setRunTimeScheduling |
( |
bool |
r | ) |
|
|
inline |
to configure the scheduling place
- Parameters
-
r | wether let runtime schedule |
◆ setSlideLen()
void INTELLI::AbstractWS::setSlideLen |
( |
size_t |
sli | ) |
|
|
inline |
set the length of slide
- Parameters
-
◆ setSysTime()
void INTELLI::AbstractWS::setSysTime |
( |
struct timeval |
tv | ) |
|
|
inline |
Set the time structure value ,the timeSys member.
- Parameters
-
◆ setTimeBased()
void INTELLI::AbstractWS::setTimeBased |
( |
bool |
ts | ) |
|
|
inline |
to configure the window type
- Parameters
-
ts | wether the slider is time-baesd |
◆ setWindowLen()
void INTELLI::AbstractWS::setWindowLen |
( |
size_t |
wl | ) |
|
|
inline |
to set the length of window
- Parameters
-
◆ timeSys
struct timeval INTELLI::AbstractWS::timeSys |
|
protected |
timeval structure from linux, <sys/time.h>
The documentation for this class was generated from the following file: