The class of split join join processor. More...

Inheritance diagram for INTELLI::SplitJoinJP:

[legend]

Collaboration diagram for INTELLI::SplitJoinJP:

[legend]

Public Member Functions
void	init (size_t sLen, size_t rLen, size_t _sysId)
	init the join processor with buffer/queue length and id More...

void	setMaxSCnt (size_t ms)
	Set the max value of sCnt variable. More...

Public Member Functions inherited from INTELLI::AbstractJP
void	inputCmd (join_cmd_t cmd)
	input an outside command More...

join_cmd_t	waitResponse ()
	wait and return the response of this join processor More...

void	setTimeBased (bool ts)
	to configure the window type More...

bool	isTimeBased ()
	to read the window type More...

void	setWindowLen (size_t wl)
	to set the length of window More...

void	setGlobalWindow (size_t wlen, size_t sli)
	set the window parameters of global window More...

virtual void	feedTupleS (TuplePtr ts)
	feed a tuple s into the s input queue More...

virtual void	feedTupleR (TuplePtr tr)
	feed a tuple r into the r input queue More...

void	setTimeVal (struct timeval tv)
	set the timeval struct More...

size_t	getTimeStamp ()
	Get the time stamp. More...

size_t	getJoinedResult ()
	get the join results More...

void	setCore (int id)
	bind to specific core More...

Public Member Functions inherited from INTELLI::AbstractC20Thread
void	startThread ()
	to start this thread

void	joinThread ()
	the thread join function

Protected Member Functions
virtual void	inlineMain ()
	The 'main' function of AbstractP. More...

void	expireS (size_t cond)

void	expireR (size_t cond)

void	joinS (TuplePtr ts)

void	joinR (TuplePtr tr)

Protected Member Functions inherited from INTELLI::AbstractJP
void	sendResponseCmd (join_cmd_t cmd)

void	sendAck ()

bool	testCmd (join_cmd_t cmd)
	To test if a cmd is remained in queue and in desired cmd. More...

size_t	oldestWindowBelong (size_t ts)
	To get the possible oldest window a time stamp belongs to. More...

Protected Attributes
TuplePtrQueue	TuplePtrQueueLocalS
	local queue storage of S, used for manage S window

TuplePtrQueue	TuplePtrQueueLocalR
	local queue storage of R, used for manage R window

size_t	sCnt = 0

size_t	sMax = 0

Protected Attributes inherited from INTELLI::AbstractJP
TuplePtrQueue	TuplePtrQueueInS

TuplePtrQueue	TuplePtrQueueInR

CmdQueuePtr	cmdQueueIn

CmdQueuePtr	cmdQueueOut

size_t	sysId

struct timeval	timeSys

bool	timeBased = false

size_t	windowLen = 0

size_t	windowLenGlobal = 0

size_t	slideLenGlobal = 0

size_t	joinedResult = 0

JoinAlgoTablePtr	myAlgo

Protected Attributes inherited from INTELLI::AbstractC20Thread
std::shared_ptr< std::thread >	threadPtr

Additional Inherited Members
Public Attributes inherited from INTELLI::AbstractJP
int	cpuBind = -1

Detailed Description

The class of split join join processor.

Member Function Documentation

void INTELLI::SplitJoinJP::init	(	size_t	sLen,
		size_t	rLen,
		size_t	_sysId
	)

inlinevirtual

init the join processor with buffer/queue length and id

Parameters

sLen	The length of S queue and buffer
rLen	The length of r queue and buffer
_sysId	The system id

Reimplemented from INTELLI::AbstractJP.

virtual void INTELLI::SplitJoinJP::inlineMain ( )

protectedvirtual

The 'main' function of AbstractP.

Reimplemented from INTELLI::AbstractJP.

void INTELLI::SplitJoinJP::setMaxSCnt ( size_t ms )

inline

Set the max value of sCnt variable.

Parameters

ms	The max value

The documentation for this class was generated from the following file: