Data::EventStream::Aggregator - Perl extension for event processing
This document describes Data::EventStream::Aggregator version 0.13
This role defines interface that should be implemented by any aggregator used with Data::EventStream. Aggregator does not have to be Moose class and literally use this role, but it should implement the methods described.
This method is invoked when a new event enters aggregator's window. Window object already includes the new event.
This method is invoked when an event leaves aggregator's window. Window object already excludes the leaving event.
This method is invoked when aggregator is used in the batch mode, each time after it finished processing another batch. Window object already empty and doesn't have any events.
This method is invoked when time changes and window contains new time limits. Note, that when window's time limits are changed this method is guaranteed to be invoked, subsequent enter and leave invocations will have the same start_time, end_time, and time_length as during the last window_update invocation.
To install Data::EventStream, copy and paste the appropriate command in to your terminal.
cpanm
cpanm Data::EventStream
CPAN shell
perl -MCPAN -e shell install Data::EventStream
For more information on module installation, please visit the detailed CPAN module installation guide.