The watermark generator

Classes
class	OoOJoin::AbstractWaterMarker
	The abstraction to describe a watermark generator, providing virtual function of deciding watermark generation. More...
class	OoOJoin::ArrivalWM
	watermark generates at time t, and every thing arrives later then t will be discard, i.e., flush finial result at t More...
class	OoOJoin::LatenessWM
	The class which generates watermark according to lateness of event time. A tuple with event time earlier than max (event time we have seen) - lateness will be discard and trigger a compute. More...
class	OoOJoin::WMTable
	The table to indexing all possible watermark generators. More...

Macros
#define	newWMTable   std::make_shared<OoOJoin::WMTable>
	(Macro) To creat a new WMTable under shared pointer.

Typedefs
typedef std::shared_ptr< class WMTable >	OoOJoin::WMTablePtr
	The class to describe a shared pointer to WMTable.

Detailed Description

This package is the key to the whole operator and generate the watermark to control processing