#include <WaterMarker/AbstractWaterMarker.h>

Go to the source code of this file.
Classes | |
| 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... | |
Namespaces | |
| OoOJoin | |
Macros | |
| #define | newLatenessWM std::make_shared<OoOJoin::LatenessWM> |
| (Macro) To creat a new PeriodicalWM under shared pointer. More... | |
Typedefs | |
| typedef std::shared_ptr< class LatenessWM > | OoOJoin::LatenessWMPtr |
| The class to describe a shared pointer to PeriodicalWM. More... | |
| #define newLatenessWM std::make_shared<OoOJoin::LatenessWM> |
(Macro) To creat a new PeriodicalWM under shared pointer.
[newPeriodicalWM]