CPStorage.h

Go to the documentation of this file.

#ifndef CPSTORAGE_H
#define CPSTORAGE_H

#include <vector>
#include <Expression.h>
#include "common.h"
#include "Tuple.h"

#include "FieldExt.h"

BOREALIS_NAMESPACE_BEGIN;

class CPStorage
{
 public:

  // constructor
  CPStorage();

  // desctructor
  ~CPStorage();


  // enqueue tuple
  void enqueue(char *tuple);

  // return tuples between first and last pointers 
  vector<char*> extract(char* first, char* last);

  // extracts tuples between start_tuple_id and end_tuple_id
  vector<char*> extract(int start_tuple_id, int end_tuple_id);

  // extracts tuple with given tuple_id
  char* extract(int tuple_id);   

  vector<char*> extract(int start_order_by, int end_order_by, ptr<Expression> order_by_field, bool revisions);


  vector<char*> extract(char* first, char* last, vector<ptr<Expression> > keys);  
  // extract this one tuple with given key
  char* extract(string tuple_key, vector<ptr<Expression> > keys);  


  // returns the first tuple with val in the order_by field
  char* findFirstValue(int val, ptr<Expression> order_by);
 
  // returns the last tuple with val in the order_by field
  char* findLastValue(int val, ptr<Expression> order_by);

  //returns a pointer to last tuple
  char* getLastTuple();
  
  //returns a pointer to the tuple that is on the n'th position from the end of storage
  char* getAtPositionFromEnd(int n);
  
  // returns the number of tuples in storage
  int getNumTuples(); 

  //eliminates all tuples with order_by value less than min_val or greater than max_val
  void discardTuples(int32 min_val, int32 max_val, ptr<Expression> order_by);

  vector<char*> getallstuff() { return _storage; }

 

  static char* modifyTuple(char *tuple, int tuple_size, TupleType type, int revision_id);
  static string concatenateKeys(char *tuple, vector<ptr<Expression> > keys);

  /*************** STATIC METHOD TO EXTRACT FROM TUPLE *******************/
  static int getKey(char *tuple);
  static int getType(char *tuple);
  static int getRevisionId(char *tuple);

 private:

  // extract the key values from the tuples and put it together 

  // using a vector to store tuples for now.
  // WHAT IS A BETTER STORAGE???? BDB?
  vector<char*> _storage;
};

BOREALIS_NAMESPACE_END;

#endif                           // CPSTORAGE_H

---