IAWJOperator.h

Go to the documentation of this file.

 
//
// Created by tony on 22/11/22.
//
 
#ifndef INTELLISTREAM_INCLUDE_OPERATOR_IAWJOPERATOR_H_
#define INTELLISTREAM_INCLUDE_OPERATOR_IAWJOPERATOR_H_
#include <Operator/AbstractOperator.h>
#include <Common/Window.h>
#include <atomic>
#include <WaterMarker/LatenessWM.h>
namespace OoOJoin {
class IAWJOperator : public AbstractOperator {
 protected:
  Window myWindow;
  size_t intermediateResult = 0;
  string algoTag = "NestedLoopJoin";
  uint64_t joinThreads = 1;
  atomic_bool lockedByWaterMark = false;
  AbstractWaterMarkerPtr wmGen = nullptr;
  void conductComputation();
 public:
  IAWJOperator() {}
  ~IAWJOperator() {}
  virtual bool setConfig(ConfigMapPtr cfg);
  virtual bool feedTupleS(TrackTuplePtr ts);
 
  virtual bool feedTupleR(TrackTuplePtr tr);
 
  virtual bool start();
 
  virtual bool stop();
 
  virtual size_t getResult();
 
};
typedef std::shared_ptr<class IAWJOperator> IAWJOperatorPtr;
#define newIAWJOperator std::make_shared<OoOJoin::IAWJOperator>
}
#endif //INTELLISTREAM_INCLUDE_OPERATOR_IAWJOPERATOR_H_