Collector
1
|
Public Member Functions | |
Processor (const tweet &twt) | |
Construct a new Processor object from a tweet. More... | |
Processor (const Processor &process)=default | |
Construct a new Processor object by copy. More... | |
Processor (Processor &&process)=default | |
Construct a new Processor object by displacement. More... | |
Processor & | operator= (const Processor &process)=default |
Overload operateur = to construct a new Cascade object by recopy. More... | |
Processor & | operator= (Processor &&process)=default |
Overload operateur = to construct a new Cascade object by recopying its right value. More... | |
~Processor () | |
Destroy the Processor object. | |
source::idf | getSource () const |
Get the Source object. More... | |
timestamp | getSourceTime () const |
Get the Source Time object. More... | |
priority_queue | getPriorityQueue () const |
Get the Priority Queue object. More... | |
std::map< timestamp, std::queue< cascade_wref > > | getFIFO () const |
Get the FIFO object. More... | |
std::map< std::string, cascade_wref > | getSymbolTable () const |
Get the Symbol Table object. More... | |
void | setSourceTime (const timestamp &src_time) |
Set the Source Time object. More... | |
void | addToFIFO (const int &pos, const cascade_wref &weak_ref_cascade) |
Add a cascade of a tweet to the FIFO from its weak reference. More... | |
void | addToSymbolTable (const std::string &key, const cascade_wref &weak_ref_cascade) |
Add a cascade of a tweet to the Symbole Table from its weak reference and the key of the tweet. More... | |
auto | addToPriorityQueue (const cascade_ref &sh_ref_cascade) |
Add a cascade of a tweet to the Priority Queue from its the share pointer of the reference. More... | |
void | decreasePriorityQueue (const priority_queue::handle_type &elt, const cascade_ref &sh_ref_cascade) |
Remove a Cascade of the Priority Queue from the share pointer that references the cascade object. More... | |
std::vector< std::string > | sendPartialCascade (const std::vector< std::size_t > &obs) |
Method to send a serie which is a partial cascade. More... | |
std::vector< std::string > | sendTerminatedCascade (timestamp &end_time, const std::size_t &min_size) |
Method to send properties which correspond to a terminated cascade. More... | |
Friends | |
class | Cascade |
std::ostream & | operator<< (std::ostream &os, std::vector< std::pair< timestamp, int > > &time_magnitude) |
Overload operator << to add time and magnitude to an output to print. More... | |
|
inline |
Construct a new Processor object from a tweet.
twt |
|
default |
Construct a new Processor object by copy.
process |
|
default |
Construct a new Processor object by displacement.
process |
|
inline |
Add a cascade of a tweet to the FIFO from its weak reference.
pos | |
weak_ref_cascade |
|
inline |
Add a cascade of a tweet to the Priority Queue from its the share pointer of the reference.
sh_ref_cascade |
|
inline |
Add a cascade of a tweet to the Symbole Table from its weak reference and the key of the tweet.
key | |
weak_ref_cascade |
|
inline |
Remove a Cascade of the Priority Queue from the share pointer that references the cascade object.
elt | |
sh_ref_cascade |
|
inline |
Get the FIFO object.
|
inline |
Get the Priority Queue object.
|
inline |
Get the Source object.
|
inline |
Get the Source Time object.
|
inline |
Get the Symbol Table object.
|
inline |
Method to send a serie which is a partial cascade.
obs |
|
inline |
Method to send properties which correspond to a terminated cascade.
end_time | |
min_size |
|
inline |
Set the Source Time object.
src_time |
|
friend |
Overload operator << to add time and magnitude to an output to print.
os | |
time_magnitude |