OoOJoin::IMAIAWJOperator Class Reference

The IAWJ operator under the simplest AQP strategy, and updates incrementally (IMA), only considers a single window and uses exponential weighted moving average for prediction. This one is EAGER join in fact. More...

#include <Operator/IMAIAWJOperator.h>

Inheritance diagram for OoOJoin::IMAIAWJOperator:

Collaboration diagram for OoOJoin::IMAIAWJOperator:

Classes
class	IMAStateOfKey

Public Member Functions
virtual bool	setConfig (ConfigMapPtr cfg)
	Set the config map related to this operator. More...
virtual bool	feedTupleS (TrackTuplePtr ts)
	feed a tuple s into the Operator More...
virtual bool	feedTupleR (TrackTuplePtr tr)
	feed a tuple R into the Operator More...
virtual bool	start ()
	start this operator More...
virtual bool	stop ()
	stop this operator More...
virtual size_t	getResult ()
	get the joined sum result More...
virtual size_t	getAQPResult ()
	get the joined sum result under AQP More...
Public Member Functions inherited from OoOJoin::MeanAQPIAWJOperator
virtual ConfigMapPtr	getTimeBreakDown ()
	get the break down information of processing time More...
Public Member Functions inherited from OoOJoin::AbstractOperator
void	setWindow (size_t _wl, size_t _sli)
	Set the window parameters of the whole operator. More...
void	setBufferLen (size_t _sLen, size_t _rLen)
	Set buffer length of S and R buffer. More...
void	syncTimeStruct (struct timeval tv)
	Synchronize the time structure with outside setting. More...

Protected Types
typedef std::shared_ptr< IMAStateOfKey >	IMAStateOfKeyPtr
Protected Types inherited from OoOJoin::MeanAQPIAWJOperator
typedef std::shared_ptr< MeanStateOfKey >	MeanStateOfKeyPtr

Protected Member Functions
void	conductComputation ()
Protected Member Functions inherited from OoOJoin::MeanAQPIAWJOperator
void	conductComputation ()
void	updateStateOfKey (MeanStateOfKeyPtr sk, TrackTuplePtr tp)
void	lazyComputeOfAQP ()
double	predictUnarrivedTuples (MeanStateOfKeyPtr px)
Protected Member Functions inherited from OoOJoin::AbstractOperator
void	setFinalProcessedTime ()
	set the final processed time for all tuples

Additional Inherited Members
Public Attributes inherited from OoOJoin::AbstractOperator
ConfigMapPtr	config = nullptr
Protected Attributes inherited from OoOJoin::MeanAQPIAWJOperator
Window	myWindow
size_t	intermediateResult = 0
size_t	confirmedResult = 0
uint64_t	windowBound = 0
double	alphaArrivalSkew = 0.125
double	betaArrivalSkew = 0.25
double	aqpScale = 0.1
atomic_bool	lockedByWaterMark = false
AbstractWaterMarkerPtr	wmGen = nullptr
StateOfKeyHashTablePtr	stateOfKeyTableR
StateOfKeyHashTablePtr	stateOfKeyTableS
tsType	lastTimeOfR = 0
tsType	timeBreakDown_index
	for time breakdown of searching index
tsType	timeBreakDown_prediction
	for time breakdown of prediction
tsType	timeBreakDown_join
	for time breakdown of join
Protected Attributes inherited from OoOJoin::AbstractOperator
struct timeval	timeBaseStruct
size_t	windowLen = 0
size_t	slideLen = 0
size_t	sLen = 0
size_t	rLen = 0
int	threads = 0
tsType	timeStep = 0
tsType	timeBreakDown_all = 0

Detailed Description

The IAWJ operator under the simplest AQP strategy, and updates incrementally (IMA), only considers a single window and uses exponential weighted moving average for prediction. This one is EAGER join in fact.

Note

require configurations:

• "windowLen" U64: The length of window
• "slideLen" U64: The length of slide
• "sLen" U64: The length of S buffer
• "rLen" U64: The length of R buffer
• "wmTag" String: The tag of watermarker, default is arrival for ArrivalWM

Warning

This implementation is putting rotten, just to explore a basic idea of AQP by using historical mean to predict future

The predictor and watermarker are currently NOT seperated in this operator, split them in the future!

Note

In current version, the computation will block feeding

follows the assumption of linear independent arrival and skewness

operator tag = "IMA"

Member Function Documentation

feedTupleR()

bool OoOJoin::IMAIAWJOperator::feedTupleR ( OoOJoin::TrackTuplePtr  tr )

virtual

feed a tuple R into the Operator

Parameters

tr

The tuple

Warning

The current version is simplified and assuming only used in SINGLE THREAD!

Returns

bool, whether tuple is fed.

Reimplemented from OoOJoin::MeanAQPIAWJOperator.

feedTupleS()

bool OoOJoin::IMAIAWJOperator::feedTupleS ( OoOJoin::TrackTuplePtr  ts )

virtual

feed a tuple s into the Operator

Parameters

ts

The tuple

Warning

The current version is simplified and assuming only used in SINGLE THREAD!

Returns

bool, whether tuple is fed.

First get the index of hash table

Reimplemented from OoOJoin::MeanAQPIAWJOperator.

getAQPResult()

size_t OoOJoin::IMAIAWJOperator::getAQPResult ( )

virtual

get the joined sum result under AQP

Returns

The result

Reimplemented from OoOJoin::MeanAQPIAWJOperator.

getResult()

size_t OoOJoin::IMAIAWJOperator::getResult ( )

virtual

get the joined sum result

Returns

The result

Reimplemented from OoOJoin::MeanAQPIAWJOperator.

setConfig()

bool OoOJoin::IMAIAWJOperator::setConfig ( INTELLI::ConfigMapPtr  cfg )

virtual

Set the config map related to this operator.

Todo:

Where this operator is conducting join is still putting rotten, try to place it at feedTupleS/R

Parameters

cfg	The config map

Returns

bool whether the config is successfully set

Reimplemented from OoOJoin::MeanAQPIAWJOperator.

start()

bool OoOJoin::IMAIAWJOperator::start ( )

virtual

start this operator

Returns

bool, whether start successfully

set watermark generator

Note

:

set window

Reimplemented from OoOJoin::MeanAQPIAWJOperator.

stop()

bool OoOJoin::IMAIAWJOperator::stop ( )

virtual

stop this operator

Returns

bool, whether start successfully

Reimplemented from OoOJoin::MeanAQPIAWJOperator.

---

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

• include/Operator/IMAIAWJOperator.h
• src/Operator/IMAIAWJOperator.cpp