Tuples.h

Go to the documentation of this file.

 
//
// Created by tony on 22/11/22.
//
 
#ifndef INTELLISTREAM_OOOTUPLE_H
#define INTELLISTREAM_OOOTUPLE_H
#include <stdint.h>
#include <string>
#include <memory>
namespace OoOJoin {
 
typedef uint64_t keyType;    
typedef uint64_t valueType;  
typedef uint64_t tsType;  
class Tuple {
 public:
  keyType key; 
  valueType payload; 
  tsType eventTime = 0;
  Tuple(keyType k);
  Tuple(keyType k, valueType v);
  Tuple(keyType k, valueType v, tsType et);
  Tuple(keyType k, valueType v, tsType et, tsType at);
  std::string toString();
  ~Tuple() {}
};
typedef std::shared_ptr<class Tuple> TuplePtr;
#define newTuple std::make_shared<OoOJoin::Tuple>
class OoOTuple : public Tuple {
 public:
  tsType arrivalTime = 0; 
  OoOTuple(keyType k) : Tuple(k) {}
  OoOTuple(keyType k, valueType v) : Tuple(k, v) { arrivalTime = 0; }
  OoOTuple(keyType k, valueType v, tsType et) : Tuple(k, v, et) { arrivalTime = et; }
  OoOTuple(keyType k, valueType v, tsType et, tsType at) : Tuple(k, v, et) { arrivalTime = at; }
  std::string toString();
  ~OoOTuple() {}
};
typedef std::shared_ptr<class OoOTuple> OoOTuplePtr;
#define newTuple std::make_shared<OoOJoin::Tuple>
class TrackTuple : public OoOTuple {
 public:
  tsType processedTime = 0;
  TrackTuple(keyType k) : OoOTuple(k) {}
  TrackTuple(keyType k, valueType v) : OoOTuple(k, v) {}
  TrackTuple(keyType k, valueType v, tsType et) : OoOTuple(k, v, et) {}
  TrackTuple(keyType k, valueType v, tsType et, tsType at) : OoOTuple(k, v, et, at) {}
  std::string toString();
  ~TrackTuple() {}
};
typedef std::shared_ptr<class TrackTuple> TrackTuplePtr;
#define newTrackTuple std::make_shared<OoOJoin::TrackTuple>
// AlianceDB
 
}
 
#endif //INTELLISTREAM_OOOTUPLE_H