The class of cell join join processor. More...

Inheritance diagram for INTELLI::CellJoinJP:

Collaboration diagram for INTELLI::CellJoinJP:

[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	feedWindowS (WindowOfTuples ws)
	Directly feed a window of tuples. More...

void	feedWindowR (WindowOfTuples wr)
	Directly feed a window of tuples. 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...

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
WindowQueue	windowQueueS

WindowQueue	windowQueueR

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 cell join join processor.

Member Function Documentation

void INTELLI::CellJoinJP::feedWindowR ( WindowOfTuples wr )

inline

Directly feed a window of tuples.

Parameters

wr	The window of r

void INTELLI::CellJoinJP::feedWindowS ( WindowOfTuples ws )

inline

Directly feed a window of tuples.

Parameters

ws	The window of s

void INTELLI::CellJoinJP::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::CellJoinJP::inlineMain ( )

protectedvirtual

The 'main' function of AbstractP.

Reimplemented from INTELLI::AbstractJP.

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