StreamStatsSample.h

Go to the documentation of this file.

#ifndef STREAMSTATSSAMPLE_H
#define STREAMSTATSSAMPLE_H

#include<sstream>

using namespace std;

struct StreamStatsSample {
        StreamStatsSample(long tv_sec, size_t tuplesEnqueued) :
                _tv_sec(tv_sec),
                _tuplesEnqueued(tuplesEnqueued)
        {
        }
        
        long _tv_sec;

        // The total number of tuples enqueued into this Stream during this sample.
        size_t _tuplesEnqueued;

        string to_string() const {
                ostringstream os;
                os << "_tv_sec = " << _tv_sec << endl
                   << "_tuplesEnqueued = " << _tuplesEnqueued << endl;
                return os.str();
        }       
};

#endif

---