BIE Overview Quick Start Theoretical overview Available methods Parallel chains Computation engine Command Line Interface Graphical User Interface Assigning Output Visualization tool Data handling Software technology Parallel debugging Results to date Recent developments Links User guide Future features Project goals Project Team Copyright and license

/home/weinberg/src/BIE/include/RecordInputStream.h // This is -*- C++ -*- #ifndef RecordInputStream_h #define RecordInputStream_h #include <string> #include <vector> #include "RecordStream.h" #include "RecordBuffer.h" #include "Serializable.h" namespace BIE { class RecordStreamFilter; class RecordInputStream; //+ CLICLASS RecordInputStream SUPER RecordStream class RecordInputStream : public RecordStream { public: ~RecordInputStream(); //+ CLIMETHOD bool nextRecord virtual bool nextRecord(); //+ CLIMETHOD bool eos virtual bool eos(); //+ CLIMETHOD bool error virtual bool error(); //+ CLIMETHOD bool isRootStream bool isRootStream(); inline string getStringValue(int fieldindex) { return rs_buffer->getStringValue(fieldindex); } inline int getIntValue (int fieldindex) { return rs_buffer->getIntValue(fieldindex); } inline double getRealValue (int fieldindex) { return rs_buffer->getRealValue(fieldindex); } inline bool getBoolValue (int fieldindex) { return rs_buffer->getBoolValue(fieldindex); } inline string getStringValue(string fieldname) { return rs_buffer->getStringValue(fieldname); } inline int getIntValue(string fieldname) { return rs_buffer->getIntValue(fieldname); } inline double getRealValue (string fieldname) { return rs_buffer->getRealValue(fieldname); } inline bool getBoolValue (string fieldname) { return rs_buffer->getBoolValue(fieldname); } inline vector<int> getIntArrayValue(int fieldindex) { return rs_buffer->getIntArrayValue(fieldindex); } inline vector<double> getRealArrayValue(int fieldindex) { return rs_buffer->getRealArrayValue(fieldindex); } inline vector<bool> getBoolArrayValue(int fieldindex) { return rs_buffer->getBoolArrayValue(fieldindex); } //+ CLIMETHOD RecordInputStream* deleteField string RecordInputStream* deleteField(string fieldname); //+ CLIMETHOD RecordInputStream* deleteField int RecordInputStream* deleteField(int fieldindex); //+ CLIMETHOD RecordInputStream* deleteRange int int RecordInputStream * deleteRange (int startfield, int endfield); //+ CLIMETHOD RecordInputStream* joinWithStream int RecordInputStream* RecordInputStream * joinWithStream(int position, RecordInputStream * stream); //+ CLIMETHOD RecordInputStream* selectFields RecordType* RecordInputStream * selectFields(RecordType * selection); //+ CLIMETHOD RecordInputStream* selectFields vector<int>* RecordInputStream * selectFields(vector<int>* selection); //+ CLIMETHOD RecordInputStream* selectFields vector<string>* RecordInputStream * selectFields(vector<string>* selection); //+ CLIMETHOD RecordInputStream* renameField string string RecordInputStream * renameField(string oldname, string newname); //+ CLIMETHOD RecordInputStream* renameField int string RecordInputStream * renameField(int fieldindex, string newname); //+ CLIMETHOD RecordInputStream* moveField string int RecordInputStream * moveField(string fieldname, int newposition); //+ CLIMETHOD RecordInputStream* moveField int int RecordInputStream * moveField(int oldposition, int newposition); //+ CLIMETHOD RecordInputStream* filterWith int RecordStreamFilter* RecordInputStream * filterWith (int position, RecordStreamFilter * filter); //+ CLIMETHOD string toString virtual string toString(); protected: // Default constructor called by sub class constructors RecordInputStream() {} void noLongerRoot(); void setAsRoot(); vector<RecordInputStream *> ris_inherited; private: RecordInputStream * createDerivative (RecordBuffer * newbuffer); bool ris_isroot; RecordStreamFilter * ris_filter; // AUTO GENERATED BY ../persistence/autopersist.py private: friend class boost::serialization::access; template<class Archive> void serialize(Archive & ar, const unsigned int version) { this->pre_serialize(ar, version); try { ar & BOOST_SERIALIZATION_BASE_OBJECT_NVP(RecordStream); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(ris_inherited); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } try { ar & BOOST_SERIALIZATION_NVP(ris_isroot); BIE_CATCH_BOOST_SERIALIZATION_EXCEPTION; } this->post_serialize(ar, version); } }; } // namespace BIE BIE_CLASS_TYPE_INFO(BIE::RecordInputStream) BIE_CLASS_EXPORT_KEY(BIE::RecordInputStream) #endif